【问题标题】:Airflow pipeline is not triggered气流管道未触发
【发布时间】:2021-12-13 04:46:40
【问题描述】:

实际上,我已经定义了从 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 * * *'
)

【问题讨论】:

  • 您能否尝试将开始日期更改为几天前,看看是否会触发?
  • 是的,它就是这样工作的。我有兴趣了解为什么它没有在预定日期触发。如果我将开始日期更改为 1 天。它有效

标签: python-3.x airflow pipeline


【解决方案1】:

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

原因是start_date 指定了您希望在数据库中包含数据的第一个日期和时间。 Airflow 将在start_date + interval 运行作业,因此在间隔过去之后(因为那是数据可用的时间)。你可以阅读更多关于它的信息herehere

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2020-05-14
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-02-10
    • 1970-01-01
    • 2020-03-21
    相关资源
    最近更新 更多