airflow - 如何修复 AIRFLOW 一日滞后问题

Question

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

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

标签： airflowairflow-scheduler

Answer 1

这就是气流的工作原理。DAG 安排在时间间隔的末尾。您可以阅读此答案以获取有关它的更多信息。

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