python - AirFlow 调度程序 - 运行日期

Question

我有一个每周一上午 11 点运行的 DAG。它于 13/05 运行，于 20/05 关闭并于 27/05 再次打开。

dag = DAG(
    'my_dag',
    description='my_desc',
    default_args=args,
    schedule_interval='0 11 * * 1',
    max_active_runs=1,
    catchup=False)

我的问题是:DAG 在 27/05 运行，但“运行日期”设置为 20/05，我不知道为什么。是因为它在 20/05 关闭并且 DAG 获得了“最后预定日期”吗？在这种情况下，下周(6 月 3 日)它将以“运行日期”设置为 27/05 或 03/06 运行？

在这种情况下，6 月 3 日的execution_date 和next_execution_date 是什么时候？

谢谢!

Answer 1

如果您查看当前 dag 的所有正在运行的任务，您将看到在 Run 处显示 schedule_interval 中定义的上一个正在运行的任务的日期时间。 Started 和Ended 显示当前任务运行的真实日期时间。在下周(6 月 3 日)，您将在 Run 中看到这个日期 `2019-05-27T11:00:00'