AirFlow 调度程序 - 运行日期

Question

我有一个 DAG，每周一运行上午 11 点。它于 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)

我的问题是：在 27/05 DAG 运行但 "run date" 设置为 20/05，我不知道为什么。是因为它在 20/05 被关闭并且 DAG 得到了 "last scheduled date" 吗？在这种情况下，下周（6 月 3 日）它将运行和 "run date" 设置为 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'

AirFlow 调度程序 - 运行日期

AirFlow scheduler - run date

python

airflow

airflow-scheduler

AirFlow 调度程序 - 运行 日期

AirFlow scheduler - run date

python

airflow

airflow-scheduler

AirFlow 调度程序 - 运行日期