气流 dag 失败...但所有任务都成功了

mel*_*r55 10 python airflow

我对我们的气流 ui 中的某些东西感到非常困惑。在树视图(和图形视图)中,dag 指示已失败。然而,它的所有成员任务似乎都成功了。您可以在下面看到它(倒数第三个):

在此处输入图片说明

有谁知道这是怎么可能的,它意味着什么,或者人们将如何调查它?

小智 7

我也有过同样的经历。所有任务都成功完成,但 DAG 失败。没有在任何日志中找到任何内容。

就我而言,是 DAG 的 dagrun_timeout 设置对于运行超过 30 分钟的任务而言设置得太低:

dag = DAG(...,
          dagrun_timeout=timedelta(minutes=30),
          ...)

Run Code Online (Sandbox Code Playgroud)

我使用的是 Airflow 版本 1.10.1。

  • 谢谢,我在这里更改了 DAG 的超时并且工作得很好 (3认同)