气流DAG由调度程序触发两次。每周DAG
由于下面的配置，周一会触发两次气流DAG。
当我使用30 11 * * 1 cron表达式时，DAG根本不触发。所以我想我必须在表达式中再加一个*。30 11 * * 1 * -它能工作。
default_args:
'start_date': airflow.utils.dates.days_ago(1)达格:schedule_interval=，30 11 * * 1 *，##，这是周一11:30的每周一次。
然而，DAG每周一被触发2次。相隔1分钟：
- 11:30:05
- 11:30:58
可能的原因是什么？
回答 3
Stack Overflow用户
发布于 2019-12-06 04:19:31
Stack Overflow用户
发布于 2019-11-13 06:56:27
6位数字cron表达式不正确，您输入的第一个数字是正确的。你做了多少次DAG？我建议您先运行schedule_interval=@weekly，看看会发生什么？
Stack Overflow用户
发布于 2019-11-19 15:40:23
气流使用的cron解析器将第六位解释为秒(如您在这里看到的：croniter.py#L14 )。
我想你的DAG还不到一分钟就结束了。在下一个调度器循环中，它看到cron调度仍然匹配(在第58秒)，因此它再次启动DAG。
我也有同样的问题，因为气流文档链接到维基百科关于cron的条目中显示了6个条目。6个条目是非标准的，并且有一个以上的实现。无论如何，对于气流，第六项被解释为秒。
您的5位cron表达式应该可以工作。也许再试一次？但是，更改dag id，否则您可能会遇到奇怪的行为: From https://cwiki.apache.org/confluence/display/AIRFLOW/Common+Pitfalls：Changing schedule interval always requires changing the dag_id, because previously run TaskInstances will not align with the new schedule interval
https://stackoverflow.com/questions/58806858
复制相似问题
腾讯云开发者
