Handle task timeouts (`execution_timeout`) at supervisor
- Dominant language
- Python
- Stars
- 46.9k
- Forks
- 17.8k
- Avg merge
- 2d 10h
- Merged PRs (30d)
- 483
Description
### Body
Right now we handle these at the task runner (fork: https://github.com/apache/airflow/blob/main/task-sdk/src/airflow/sdk/execution_time/task_runner.py#L1149-L1165) instead of handling it at the supervisor. We should move the check to the supervisor level.
### Committer
- [x] I acknowledge that I am a maintainer/committer of the Apache Airflow project.
Contributor guide
Research direction
Start at task-sdk/src/airflow/sdk/execution_time/task_runner.py#L1149-L1165 and trace how execution_timeout is currently handled by the task runner. Then locate the supervisor entry point and its related tests. Done means the timeout check is handled at the supervisor level rather than the task runner, with existing timeout behavior preserved.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- python
- Domain
- backend
- Issue type
- Refactor
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Active
- Clarity
- Mostly clear
- Newbie friendliness
- 65/100