| catchup=True | 补齐 start_date 以来的每个调度周期 |
|---|---|
| catchup=False | 跳过历史，只跑当前及之后 |
| 适用 | 历史数据无需回刷时关闭；需要补历史时用受控的 backfill |
Airflow DAG 参数
Airflow DAG 参数
from datetime import datetime
from airflow import DAG
dag = DAG(
'daily_orders',
start_date=datetime(2026, 1, 1),
schedule='0 2 * * *',
catchup=False, # 上线后不补历史
max_active_runs=1,
)开启 catchup 且 start_date 很早时会瞬间创建成百上千个 DagRun，要配合 max_active_runs 与并发限制。