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

道练习

实现 Trigger Rule

创建工作流后，您意识到如果至少有一个任务失败，Dag 能提供一些状态更新会更好。您决定实现一个任务，在 Dag 上执行 one failed 检查，以便当 Dag 中任一任务失败时提醒您。

其他所有任务都已定义，且 task 与 dag 对象已为您导入。

说明

100 XP
  • 导入用于触发规则的合适库。
  • 为 notify_on_failure 任务添加相应的触发规则属性。
  • 设置该属性，使该任务在一个或多个上游任务失败时触发。
  • 将 notify_on_failure 设为两个 transform 任务的下游依赖。