气流-达格没有按预定时间执行。

Question

我想让我的伙伴们第一次在2:00 AM on 25th上跑步，然后从周二开始在2:00 am坐下来跑步。

下面是我的日程安排。

with DAG(
    dag_id='in__xxx__agnt_brk_com',
    schedule_interval='0 2 * * 2-6',
    start_date=datetime(2022, 10, 24),
    catchup=False,
) as dag: 

在气流用户界面上，它也表明我的第一次运行应该是在25th 2:00 AM上。但不幸的是，达格斯没有按时执行。

​

​

我在这里错过了什么？

Answer 1

气流计划在当地时间凌晨2点，也就是世界协调时间早上6点。

查看如何在dag：https://airflow.apache.org/docs/apache-airflow/stable/timezone.html中指定时区的链接

Answer 2

您应该查阅有关dag间隔的文档。

你的达格在二十五号没有跑

• 你的开始日期是2022-10-24。

这将创建一个2022-10-24-2022-10-25的进程间隔.

• 你设置了catchup=False

是你在二十五号午夜后创建的。第24天的进程间隔已经过去，而您已经拒绝追赶。

• 下一个进程计划在2022-10-25。

这将创建一个2022-10-25 - 2022-10-26的进程间隔。

您的达格将在协调世界时26日凌晨2点运行。