Airflow:是否可以在 DAG 中配置任务级超时?
Airflow : Is it possible to configure task-level timeout in a DAG?
Airflow : 是否可以在 DAG 中配置任务级超时。
我希望 运行 无限期地阻止任务。根据我的理解,只有在任务完成并超过 SLA 后,sla 参数才会到位。
对于 Airflow 中 Operator 的超时,您可以添加 execution_timeout
参数。来自文档:
exuction_timeout (datetime.timedelta) – max time allowed for the execution of this task instance, if it goes beyond it will raise and fail
它需要 datetime.timedelta
,例如timedelta(hours=1)
任务最多 1 小时。
请注意,对于传感器 execution_timeout
不起作用。传感器需要 timeout
参数。
Airflow : 是否可以在 DAG 中配置任务级超时。
我希望 运行 无限期地阻止任务。根据我的理解,只有在任务完成并超过 SLA 后,sla 参数才会到位。
对于 Airflow 中 Operator 的超时,您可以添加 execution_timeout
参数。来自文档:
exuction_timeout (datetime.timedelta) – max time allowed for the execution of this task instance, if it goes beyond it will raise and fail
它需要 datetime.timedelta
,例如timedelta(hours=1)
任务最多 1 小时。
请注意,对于传感器 execution_timeout
不起作用。传感器需要 timeout
参数。