1. 学ぶ
    2. /
  2. コース
    3. /
  3. Python で学ぶ Apache Airflow 入門
Connected

演習

@task.branch の定義

Airflow における条件分岐ロジックの仕組みを学んだあと、@task.branch デコレータを実際に試してみましょう。現在の実行日が新しい年（たとえば 2025 年から 2026 年）を表している場合に、異なるコードパスを実行したいと思います。

DAG はあらかじめ定義されており、関連するタスクも用意されています。ここでは @task.branch の実装に取り組みましょう。

指示

100 XP
  • 現在の実行年と前回の実行年を比較するために、適切な Airflow の日付テンプレート変数を year_check のパラメータとして追加しましょう。
  • 各日付パラメータの先頭 4 文字を取り出して、current_year と previous_year に代入しましょう。
  • current_year_task と new_year_task への依存関係を設定しましょう。