任务重试时 Airflow DAG 运行 失败

Airflow DAG run fails when task is up for retry

在 DAG 的默认参数中,我设置了 retryretry_delay 参数。当我监视 UI 时,如果任务失败,它会短暂地将状态更改为 "retry" 但紧随其后,DAG 状态将设置为 "FAILED" 等任务(应该是重试)卡在排队状态。在这种情况下,dagrun 不应该保持 "running" 状态,因为失败的任务需要重试吗?

我花了一些时间搜索有关 dagrun 如何更改状态的文档和代码,但一直无法弄清楚。

此问题已在即将发布的 Airflow 1.8 版本中得到修复。参考以下 JIRA 工单:

  1. Retry not honored
  2. Retry delay not honored