我有一个 DAG,它每天在 3:00 运行,过去几周运行正常。
我已将日期更新为现在 7:00 运行,但显然在过去 2 天内它没有运行。我可以看到这两天的任务状态为“正在运行”(绿色),但没有触发任何命令。
是否需要做更多的事情来改变 DAG 的运行时间?
我知道过去解决此问题的一种方法是在元数据库中清除此 DAG 的任务,并更新 start_date,但我宁愿避免再次这样做。
有人有建议吗?
最佳答案
为了安排 dag,Airflow 只查找最后一个 execution date
并总结 schedule interval
.如果此时间已过,它将运行 dag。您不能简单地更新开始日期。
一个简单的方法是编辑您的 start date
和 schedule interval
,重命名您的 dag(例如 xxxx_v2.py)并重新部署它。
关于 Airflow :在 Airflow 中更改 DAG 的 crontab 时间,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37294560/