Airflow DAG 不遵循时间表

Question

我有一个每月安排一次的 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 在手动执行时完美运行。我是不是设置错了什么？

谢谢!

Answer 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 中有深入解释。 .