1. Learn
    2. /
  2. Courses
    3. /
  3. Python 中的 Apache Airflow 入门
Connected

Exercise

定义一个 @task.branch

在学习了 Airflow 中条件逻辑的强大作用后，您希望试用一下 @task.branch 装饰器。您想在当前执行日期代表新年时（例如 2026 vs 2025）走不同的代码路径。

Dag 和相关任务已为您定义。您当前的任务是实现 @task.branch。

Instructions

100 XP
  • 将合适的 Airflow 日期模板变量作为参数添加到 year_check，用于比较当前与上一执行年的年份。
  • 通过从每个日期参数中切片前 4 个字符来赋值 current_year 和 previous_year。
  • 为 current_year_task 和 new_year_task 设置依赖关系。