Airflow BranchPythonOperator分支下必执行任务的Trigger Rule配置问题

直接为Task3配置trigger_rule="all_done"即可，你当前设计的任务依赖结构不需要调整，完全可以满足「Task3无条件执行」的需求。

• all_done的触发判定逻辑为：所有上游任务均进入终态后即触发当前任务，这里的终态覆盖任务所有可能的结束状态：执行成功、执行失败、被调度跳过、被人工标记为成功/失败，不会要求上游任务必须处于成功状态，被跳过的上游任务不会阻断该规则生效。
• 结合你的分支场景，触发逻辑完全符合预期：
  • 当Task1判断需要执行Task2时：Task2进入执行流程（无论最终成功/失败都算终态），未被选中的TaskD会被BranchPythonOperator自动标记为跳过状态，两个上游任务都进入终态后Task3自动触发
  • 当Task1判断不需要执行Task2时：Task2被自动标记为跳过状态，被选中的Dummy任务TaskD正常执行完成进入成功终态，两个上游任务都进入终态后Task3自动触发

• all_success：要求所有上游任务全部执行成功才触发，只要存在上游失败、被跳过的情况就不会运行，完全不符合需求
• one_success：只要任意一个上游执行成功就触发，若出现Task2执行失败、TaskD被跳过的场景，没有上游任务处于成功状态，Task3将不会被调度
• one_failed：只要任意一个上游执行失败就触发，若出现Task2执行成功、TaskD被跳过的场景，没有上游任务处于失败状态，Task3将不会被调度
• none_failed：要求所有上游任务没有失败状态才触发，若Task2执行失败，Task3会被直接阻断，不符合要求

注：该逻辑在Airflow 1.10及以上所有版本中均成立，不存在版本兼容问题。

内容的提问来源于stack exchange，提问作者seou1