execution_timeout 和 dagrun_timeout 之间的气流有什么区别？

Question

我是 airflow 的新手，想知道 Airflow 中 execution_timeout 和 dagrun_timeout 之间的区别。实际上，在我的代码库中，我目前正在使用 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。