GautamSharma99 opened a new pull request, #69734:
URL: https://github.com/apache/airflow/pull/69734
PR body
Deferred tasks could exceed their configured `execution_timeout` because
every resumed execution received the full timeout again. Their deferred trigger
deadline also ignored the task execution deadline.
This change:
- Sets the deferred deadline to the earlier of `trigger_timeout` and the
task's execution deadline.
- Applies only the remaining execution time when a deferred task resumes.
- Immediately raises `AirflowTaskTimeout` when the timeout elapsed while
the task was deferred.
- Adds regression coverage for execution-only, trigger-first,
execution-first, and already-expired cases.
Tests:
- Execution API task instance tests: 190 passed, 4 skipped
- Task SDK execute callable tests: 8 passed
- Execution API suite: 521 passed, 4 skipped
- Ruff, formatting, mypy, and prek checks passed
--
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]
