Airflow :在 Airflow 中更改 DAG 的 crontab 时间

标签 airflow

我有一个 DAG,它每天在 3:00 运行,过去几周运行正常。

我已将日期更新为现在 7:00 运行,但显然在过去 2 天内它没有运行。我可以看到这两天的任务状态为“正在运行”(绿色),但没有触发任何命令。

是否需要做更多的事情来改变 DAG 的运行时间?

我知道过去解决此问题的一种方法是在元数据库中清除此 DAG 的任务,并更新 start_date,但我宁愿避免再次这样做。

有人有建议吗?

最佳答案

为了安排 dag,Airflow 只查找最后一个 execution date并总结 schedule interval .如果此时间已过,它将运行 dag。您不能简单地更新开始日期。
一个简单的方法是编辑您的 start dateschedule interval ,重命名您的 dag(例如 xxxx_v2.py)并重新部署它。

关于 Airflow :在 Airflow 中更改 DAG 的 crontab 时间,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37294560/

相关文章:

python - Airflow CeleryExecutor - 'int' 对象在 Celery 中没有属性 'startswith'

airflow - 如何经济高效地配置 Google Cloud Composer

python - Airflow :无法配置处理程序 "processor"

docker - 无法在Docker中连接到Airflow Web服务器

docker - Kubernetes 部署只读文件系统错误

python - 如何使用 Airflow 变量动态运行 DAG 的多个作业

google-cloud-dataproc - 云 Composer 任务无法创建 dataproc 集群

airflow - 如何在 Airflow 中实现轮询?

python - Airflow 中的着陆时间是什么意思?