气流 DAG 未遵循计划

【问题标题】：Airflow DAG Not following schedule气流 DAG 未遵循计划
【发布时间】：2021-05-03 18:18:42
【问题描述】：

我有一个每月安排一次的 DAG。我的问题是调度程序没有开始工作：

args = {
    'owner': 'Airflow',
    'start_date': dates.days_ago(1),
    'email': ['sinistersparrow1701@gmail.com', 'rich@offrs.com'],
    'email_on_failure': True,
    'email_on_success': True,
}

dag = models.DAG(
    dag_id='Offrs_TAX_ASSESSOR_MASTER_Production',
    default_args=args,
    schedule_interval= '0 0 1 * *',
    catchup=False
)

我尝试了 0 0 1 * * 并尝试了@Monthly。它不是开火。 DAG 在手动执行时可以完美运行。是不是我设置有问题？

谢谢！

【问题讨论】：

标签： airflow airflow-scheduler

【解决方案1】：

不要在start_date 中使用动态值。

args = {
    'owner': 'Airflow',
    'start_date': datetime(2021, 4, 1),
    'email': ['sinistersparrow1701@gmail.com', 'rich@offrs.com'],
    'email_on_failure': True,
    'email_on_success': True,
}

简单来说Airflow计算start_date+schedule_interval并在间隔结束时执行任务。当您使用动态start_date 时，您可能会遇到间隔永远不会结束的情况，因为基点总是在移动。 docs 对此进行了深入解释。

【讨论】：