Shally-Katariya opened a new pull request, #60522: URL: https://github.com/apache/airflow/pull/60522
## Summary Fixes #60517 by handling `TaskDeferralTimeout` during task execution cleanup. ## Problem Deferred tasks that exceed `execution_timeout` raise `TaskDeferralTimeout`, which was not previously caught by the task runner. As a result, `on_kill()` was not invoked and external jobs continued running on retries. ## Solution Catch `TaskDeferralTimeout` alongside `AirflowTaskTimeout` in `task_runner.py`, ensuring consistent cleanup behavior for deferred task timeouts. This follows the approach suggested in the issue. ## Testing - Verified the change using Breeze - Added a minimal test for the deferral timeout case -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
