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 参数。