Airflow DAG由调度程序触发两次。每周DAG

Question

气流DAG在星期一针对以下配置触发两次。

[当我使用30 11 * * 1 cron表达式时，DAG根本不会触发。所以想通了，我必须在表达式中再加上一个*。30 11 * * 1 *-有效。

default_args:
'start_date': airflow.utils.dates.days_ago(1)

DAG：schedule_interval = 30 11 * * 1 *，##这是每周一次在星期一11:30运行。

但是，DAG每个星期一都会触发两次。相距1分钟：

• 11:30:05
• 11:30:58

可能是什么原因？

Answer 1

6位cron表达式不正确，您输入的第一个正确。您运行了DAG几次？我建议您尝试先运行schedule_interval=@weekly，然后看看会发生什么？