1. Learn
    2. /
  2. Courses
    3. /
  3. Pythonで学ぶ Apache Airflow 入門
Connected

Exercise

BranchPythonOperator を定義する

Airflow の条件分岐ロジックの強力さを学んだので、BranchPythonOperator を試してみましょう。現在の実行日が新しい年（例: 2020 vs 2019）である場合に、別のコードパスを実行したいとします。

DAG と対象のタスクはすでに定義されています。あなたの作業は BranchPythonOperator を実装することです。

Instructions

100 XP
  • 関数 year_check の中で、現在の実行日の年が直前の実行日の年と異なるかどうか（つまり、適切な Airflow テンプレート変数同士で年が異なるか）を判定するようにコードを設定してください。
  • 適切な引数を追加して BranchPythonOperator を完成させてください。
  • current_year_task と new_year_task の依存関係を設定してください。