rjgoyln opened a new pull request, #72591: URL: https://github.com/apache/airflow/pull/72591
## Summary The triggerer calls a trigger's `on_kill()` only when `asyncio.CancelledError` propagates out of `run()`. Both Dataproc submit triggers catch it and return, so on Airflow 3.3+ killing or clearing a deferred task leaves: - the Dataproc job still running - `Trigger exited without sending an event. Dependent tasks will be failed.` in the triggerer log Re-raising restores the cleanup path that migrating these triggers to `on_kill()` was meant to keep. The pre-3.3 branch handles cancellation inline and is left alone, so the regression tests are scoped to 3.3+. --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Claude Code (Opus 5) Generated-by: Claude Code (Opus 5) following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) 🤖 Generated with [Claude Code](https://claude.com/claude-code) -- 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]
