Airflow开启catchup=True后后续任务状态为no_status无法启动如何解决

核心问题修复 #

1. 修正start_date类型错误 #

你当前配置中的start_date为字符串格式，Airflow调度要求start_date必须为datetime对象，字符串解析异常会导致回溯任务的执行时间计算错误，后续DAG Run的任务状态无法正常流转，出现no_status问题。
修改代码：

from datetime import datetime
default_args = {
    "owner": "me",
    "retries": 2,
    "retry_delay": timedelta(minutes=2),
    "sla": timedelta(hours=1),
    "start_date": datetime(2021, 1, 1, 0, 0), # 替换原有字符串格式的start_date
}

2. 调整max_active_runs配置验证调度逻辑 #

你设置了max_active_runs=1，同一时间仅允许1个DAG Run运行。如果首个DAG Run的状态没有被正确标记为最终成功（比如子任务回调异常、元数据写入失败），调度器会判定仍有活跃DAG Run，不会触发后续回溯任务的调度，导致后续任务停留在no_status状态。
验证方案：

• 确认首个DAG Run的状态为success，所有子任务均运行完成无异常
• 临时将max_active_runs调整为3~5，观察后续任务是否正常启动

3. 修复未定义参数问题 #

你代码中op_args传入的exe_date变量未在DAG中定义，会导致任务初始化失败，阻塞调度流程。你可以通过Airflow内置模板变量传递执行日期：

ingest_task = PythonOperator(
    task_id=f"ingest_{dst.get('target_name')}",
    python_callable=run_ingestion,
    op_args=[logger, "{{ execution_date }}", dst],
    provide_context=True
)

子任务也同步修改op_args的exe_date参数即可。

辅助排查手段 #

如果以上修改后问题仍未解决，按照以下步骤排查：

• 查看调度器日志，搜索对应DAG ID的报错信息，排查是否有依赖缺失、元数据库锁表问题
• 若使用Airflow 2.x版本，执行airflow dags reserialize重新序列化DAG配置，清除解析缓存
• 检查SLA配置是否触发了异常中断，若回溯批次的执行时间远超SLA阈值，可临时关闭SLA验证测试

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