タスクの実行順序を定義する
ビットシフト構文を学んだところで、タスクの実行順序を定義しましょう。現在、cleanup、consolidate、push_data の3つのタスクが定義されています。
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()