为什么我所有的 Airflow dags 都落后了？

Question

我现在正在设置 Airflow 并喜欢它，除了我的狗永远落后的事实。请参阅下图 - 这是在 2/19 UTC 时间 15:50 拍摄的，您可以看到，对于每个 dag，它们应该在上次运行和当前时间之间再运行一次（有一对夫妇，这不是真的 - 这些人目前已关闭）。有没有我错过的一些配置？

Answer 1

虚惊！Airflow 只是将执行时间标记为与我预期的不同。结果表明，在 15:00 运行的每小时作业的标签为“14:00”，并包含最多 14:00+1:00 的数据。

从https://airflow.apache.org/scheduler.html：

请注意，如果您在一天的 schedule_interval 上运行 DAG，标记为 2016-01-01 的运行将在 2016-01-01T23:59 之后不久触发。换句话说，一旦它涵盖的时间段结束，就会启动作业实例。

让我们重复一遍调度程序在开始日期之后的一个 schedule_interval 时间段运行您的作业，在周期结束时。