Airflow使用ExternalTaskSensor报AirflowSensorTimeout超时问题

从报错首行日志就能直接定位核心问题：

poking for tasks None in dag xiezhuan188 on 2022-06-11T08:01:00+00:00...

问题1：未指定要等待的外部任务ID #

你当前的Sensor配置里没传external_task_id参数，所以Sensor默认查找ID为None的不存在任务，哪怕DAG B的task2已经跑成功，也永远匹配不到目标。
补充：如果不传external_task_id，Sensor默认会等待外部DAG整体运行状态符合预期，不会定向等待单个task2，不符合你的使用场景。

问题2：执行日期(execution_date)不匹配 #

ExternalTaskSensor默认拿自身所在任务的execution_date去匹配外部任务的execution_date，从日志看两边时间完全对不上：

• Sensor等待的外部任务执行日期：2022-06-11T08:01:00+00:00
• DAG B的task2实际成功的执行日期：2022-06-12T08:08:15
  时间差超过1天，哪怕你补了正确的task_id，也会因为匹配不到对应执行日期的任务实例一直探测直到超时。
  这个问题在主动触发跨DAG依赖的场景非常常见：你用DAG A的task1主动触发DAG B运行时，手动/API触发生成的DAG Run执行日期，和DAG A自身调度生成的执行日期不会天然对齐。

修复步骤 #

1. 补全external_task_id参数，填入DAG B中task2的实际任务ID
2. 对齐两边执行日期，根据你的触发场景选对应方案：
   • 如果两个DAG都是按固定周期调度、且调度周期完全一致，检查两边DAG的start_date、schedule_interval、时区配置完全相同，保证同周期生成的execution_date一致，存在固定时差的话用execution_delta参数传时间差即可
   • 如果是用TriggerDagRunOperator主动触发DAG B，推荐配置execution_date_fn参数，动态获取触发DAG B时生成的DAG Run执行日期做匹配，避免硬编码时间差
3. 把timeout参数调整为大于DAG B从触发到task2跑完的最大预期时长，避免任务还没跑完就提前超时

修复后参考配置 #

from datetime import timedelta
from airflow.sensors.external_task import ExternalTaskSensor

wait_b_task2 = ExternalTaskSensor(
    task_id='wait_b_task2',
    external_dag_id='xiezhuan188',
    external_task_id='你的DAG B task2实际ID',  # 之前缺失该参数才会出现tasks None报错
    timeout=3600,  # 按实际场景设置，单位秒，示例为1小时
    retries=1,
    allowed_states=['success'],
    check_existence=True,
    mode='reschedule',
    # 固定时差场景用这个，示例为东八区和UTC时差8小时，按实际差值调整
    execution_delta=timedelta(hours=8),
    # TriggerDagRun触发场景推荐用下面的函数动态取执行日期，替代execution_delta
    # execution_date_fn=lambda logical_date, **context: logical_date,
    dag=dag
)

校验方式 #

配置修改后重跑DAG A，观察Sensor日志，确认不再出现poking for tasks None的提示，且日志里打印的等待执行日期和DAG B中task2实际成功的执行日期完全一致，即可正常等待到目标任务成功，不会再触发超时。

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