Airflow DAG执行日期滞后1个月如何调整为实际运行日期

核心需求实现方案 #

你描述的Airflow调度日期差问题是平台原生设计导致的，execution_date默认取值为调度周期的起始时间，你想要让业务逻辑中用到的日期和实际运行日期一致，完全可以通过{{ next_ds }}变量实现，这是成本最低、风险最小的方案。

{{ next_ds }}的取值正好是当前调度周期的结束日期，也就是任务实际触发运行的日期，和你的需求完全匹配：

• 7月25日实际执行的回溯任务，{{ next_ds }}值为2021-07-25
• 8月25日实际执行的任务，{{ next_ds }}值为2021-08-25

你只需要把业务代码中所有引用{{ ds }}（即execution_date对应日期字符串）的位置，全部替换为{{ next_ds }}即可，不需要调整DAG的调度配置，也不会影响catchup回溯逻辑的正常运行。

补充说明 #

如果你使用的是Airflow 2.2及以上版本，也可以用语义更直观的{{ data_interval_end }}变量，取日期格式的写法为{{ data_interval_end | ds }}，效果和{{ next_ds }}完全一致。

不建议强制修改DAG调度配置来让execution_date本身等于运行日期，execution_date是Airflow的核心元数据，强行调整会导致调度逻辑紊乱、元数据与日志匹配异常等问题，使用内置变量替换业务日期引用是最优解决方案。

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