Apache Airflow DAG条件分支任务异常：配置触发规则后提前运行

你当前配置的依赖关系中，Task2的上游仅为Task0，只要Task0运行完成，Task2就会满足上游依赖条件开始调度，完全不会等待Task1的运行结果，这是Task2提前启动的核心原因。

1. 调整任务依赖关系 #

移除Task0到Task2的直接依赖，将Task2的上游改为Task1，调整后依赖如下：

Task0 >> Task1
Task1 >> Task1a
Task1 >> Task2

2. 配置对应触发规则 #

• Task1a保留默认的all_success触发规则即可，保证仅当Task1运行成功时才会被触发
• Task2的触发规则改为all_failed，仅当Task1运行失败时才会被触发

3. 配置DAG整体成功逻辑（避免整个DAG标记为失败） #

新增一个统一的结束节点，设置触发规则为one_success，让Task1a和Task2都指向这个结束节点，保证两个分支只要有一个运行成功，整个DAG就会标记为成功，示例代码如下：

# 新增结束虚拟任务
end_task = DummyOperator(
    task_id='end_task',
    trigger_rule='one_success',
    dag=dag
)

# 补充最终依赖
Task1a >> end_task
Task2 >> end_task

调整后的运行逻辑完全符合你的预期：

• Task1运行成功：触发Task1a运行，Task2被自动标记为跳过，最终Task1a跑完后触发end_task，DAG整体标记为成功
• Task1运行失败：触发Task2运行，Task1a被自动标记为跳过，最终Task2跑完后触发end_task，DAG整体标记为成功

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