未触发气流管道

Question

实际上我已经定义了从 2021 年 12 月 12 日开始的管道开始日期。这与新加坡时间 2021 年 12 月 13 日凌晨 4 点相同。默认情况下，管道采用 utc，我将其设置为 utc 晚上 8 点即 4 am sgt 管道似乎没有在新加坡时间凌晨 4 点触发，我不明白为什么管道没有被触发？下面是 dag 配置

dag = DAG(
    'test',
    start_date=datetime.datetime(year=2021,month=12,day=12),
    schedule_interval='0 20 * * *'
)

Answer 1

尝试将开始日期更改为几天后，它会被触发。

原因是 start_date 指定了您希望将数据存入数据库的第一个日期和时间。 Airflow 将 运行 在 start_date + interval 的作业，所以在间隔过去之后（因为那是数据可用的时候）。您可以阅读更多相关信息 here and here。