气流中的 execution_timeout 和 dagrun_timeout 有什么区别?

Rav*_*Raj 6 directed-acyclic-graphs airflow

我是新来的气流,想知道之间的区别execution_timeoutdagrun_timeout气流。实际上,在我的代码库中,我目前正在使用,execution_timeout但有些 dag 不尊重超时。

bos*_*jak 6

文档

execution_timeout (datetime.timedelta) – 允许执行此任务实例的最大时间,如果超过它会引发并失败。

dagrun_timeout (datetime.timedelta) – 指定在超时/失败之前 DagRun 应该运行多长时间,以便可以创建新的 DagRun

execution_timeout指任务实例的执行,而dagrun_timeout大约是它可以由许多任务的整个DAG。

要了解为什么您的任务不遵守超时,您需要提供更多信息,最好提供一个最小示例