CODEWITHSUNDEEP
airflowairflow-scheduler
Nixon Raphy
Nixon Raphy

Reputation: 332

Airflow : Is it possible to configure task-level timeout in a DAG?

Airflow : Is it possible to configure task-level timeout in a DAG .

I wished to prevent a task from running indefinitely . According to my understanding sla parameters will come in place only once the task gets completed and overshoots the SLA .

Upvotes: 3

Views: 2250

Answers (1)

Blokje5
Blokje5

Reputation: 5003

For timeouts on Operators in Airflow you can add the execution_timeout parameter. From the docs:

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

It expects a datetime.timedelta, e.g. timedelta(hours=1) for a max of 1 hour for the task.

Note that for sensors execution_timeout does not work. Sensors expect a timeout parameter instead.

Upvotes: 5

Related Questions