如何修复 AIRFLOW 一日滞后问题

Question

我有一个 DAG，开始日期为 2021-09-16 ，计划间隔为 '0 8 * * *'。 所以在第 17 天，我看到气流计划在第 16 天运行。

谁能帮我解决这个问题， 我想在第 17 天执行第 17 天的数据。

Answer 1

这就是 Airflow 的工作原理。 DAG 安排在时间间隔的末尾。您可以阅读this answer 了解更多信息。

这就是说 Airflow 2.2.0 版本现在位于 beta testing 中，其中包括 AIP-39 Richer scheduler_interval，它将“何时运行”与“要处理的数据窗口”分离。因此，在不久的将来，您所要求的将成为可能。