| Sensor 方式 | ExternalTaskSensor 匹配同一逻辑日期 |
|---|---|
| 产出检查 | 查分区或标记文件，不依赖调度器状态 |
| 时间对齐 | 频率不同需自定义日期映射函数 |
| 数据集 | Airflow Dataset 也可触发下游 |
ExternalTaskSensor 用法
ExternalTaskSensor 用法
from airflow.sensors.external_task import ExternalTaskSensor
wait_upstream = ExternalTaskSensor(
task_id="wait_upstream",
external_dag_id="ods_orders",
external_task_id="load",
allowed_states=["success"],
timeout=3600,
mode="reschedule",
)上游任务改名会让 Sensor 永远等不到；发布上游前先搜一遍有哪些下游在依赖它。