首页/数据/数据工程与 ETL 速查/Airflow 任务状态机
本包目录(311 条)

Airflow 任务状态机

任务实例经历 queued 到 running 再到 success 或 failed,还有 up_for_retry、upstream_failed、skipped、deferred;排障顺序是先读状态再读日志。

queued已排入执行器队列,等槽位
up_for_retry失败后等待重试间隔
upstream_failed上游失败导致未执行
deferred被延迟,等触发器唤醒

查状态与清理重跑

查状态与清理重跑
airflow tasks states-for-dag-run daily_orders <run_id>
airflow tasks list daily_orders --tree
airflow tasks clear daily_orders -t load -s 2026-10-11 -e 2026-10-11
任务长期卡 queued 多为槽位不足或 worker 掉线;卡 running 则看执行器心跳与被 kill 容器的日志。

易错点

  • 把重试次数配成 0,偶发抖动会直接暴露成事故
  • tasks clear 会连带清掉下游状态,误用会触发大范围重跑

数据来源与参考

  • Apache Airflow 官方文档:Task Instances 与 States
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌