AyushkhatiDev opened a new pull request, #71528:
URL: https://github.com/apache/airflow/pull/71528
## Summary
Fixes #71514.
`GKEStartPodOperator` did not respect `execution_timeout` when
`deferrable=True` because its custom `invoke_defer_method` did not
propagate the execution deadline to `GKEStartPodTrigger`.
### What changed
- Translate `execution_timeout` into an absolute `_execution_deadline`
anchored to the task instance `start_date`.
- Pass the deadline through `trigger_kwargs` to `GKEStartPodTrigger`.
- Add a buffered `defer.timeout` backstop so the trigger can emit its
timeout event before the framework timeout fires.
- Preserve `trigger_kwargs` in `GKEStartPodTrigger.serialize()` so the
deadline survives trigger serialization/restarts.
- Add regression tests covering deadline propagation, no-timeout
behavior, existing `trigger_kwargs`, and trigger serialization.
### Testing
- `TestGKEStartPodOperator`: 16 passed
- `GKEStartPodTrigger` serialization test: passed
- Ruff format/check: passed
One broader trigger test run encountered an unrelated local
`ModuleNotFoundError: airflow_shared` in the test infrastructure.
The affected serialization test and all operator tests for this change
passed successfully.
--
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]
