定義任務的執行順序
你已經學過位移運算子語法，現在該來定義任務的執行順序了。你目前有三個已定義的任務：cleanup、consolidate 和 push_data。
airflow.sdk 中的 dag 與 task 裝飾器已經匯入。
本練習屬於課程
Python 中的 Apache Airflow 入門
練習說明
- 使用位移語法，設定
cleanup任務在consolidate任務之前先執行。 - 設定接著執行
consolidate，最後執行push_data任務。
動手互動練習
試著完成這個範例程式碼，體驗一下這個練習。
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()