airflow - Airflow 中的 execution_timeout 和 dagrun_timeout 有什么区别？

Question

我是 Airflow 的新手，想知道 execution_timeout 之间的区别和 dagrun_timeout在 Airflow 中。实际上，在我的代码库中，我目前正在使用 execution_timeout但一些 dags 不尊重超时。

Answer 1

来自 documentation :

execution_timeout (datetime.timedelta) – max time allowed for the execution of this task instance, if it goes beyond it will raise and fail.

dagrun_timeout (datetime.timedelta) – specify how long a DagRun should be up before timing out / failing, so that new DagRuns can be created

execution_timeout指的是TaskInstance的执行，而 dagrun_timeout是关于可以包含许多任务的整个 DAG。
要了解您的任务为何不遵守超时，您需要提供更多信息，最好提供 minimal example .