airflow - 检索气流中追赶=真的预定时间

Question

我有一个计划每天通过当前日期调用脚本的 dag，所以我通过{{ ds }}来获取执行日期。

在我的 dag 没有运行的日子里，我有catchup = True。所以 dag 需要通过预定日期，而不是任务的执行日期才能完成，这样 dag 无法运行当天的活动仍然完成。

我怎样才能做到这一点？

标签： airflow

Answer 1

据我了解您的情况，这execution_date正是您所需要的。

这个名字可能有点误导，但实际上它是用预定的时间戳填充的。