时间戳

首页 > 解决方案 > 气流从昨天开始 Dag

airflow - 气流从昨天开始 Dag

问题描述

当我在气流上部署新的 dag 时，假设我今天（4 月 28 日）部署它。我的 Cron 表达式是这样的：0 3 * * *，那么我希望第一次运行是在29 April at 3 am. however, I get a run as soon as deploy with this run id: 2021-04-27, 03:00:00`。

达格代码：

DAG(
    dag_id="namexx",
    schedule_interval='0 3 * * *',
    max_active_runs=1,
    is_paused_upon_creation=False,
    dagrun_timeout=timedelta(hours=1),
    catchup=False,
    default_args={
        "start_date": datetime(2021, 1, 1),
        "retries": 0,
        "retry_delay": timedelta(minutes=1)
    }

)

知道为什么吗？

标签： airflow

解决方案

这是意料之中的。气流在间隔结束时调度 D​​AG。如果start_date是2021-01-01并且间隔是每小时一次，一旦部署 DAG，就会触发一次运行。

另请参阅有关此主题的先前答案 1和答案 2

推荐阅读