mobuchowski opened a new pull request, #65714: URL: https://github.com/apache/airflow/pull/65714
If the API rejects the worker's state report (e.g. returns 409 because the server already moved the TI to a terminal state, or due to other bug, like the one fixed by #65594), the resulting exception escapes `run()` and skips `finalize()`, so listeners like OpenLineage emit a `START` with no matching `COMPLETE`/`FAIL`. This PR wraps the terminal-state `SUPERVISOR_COMMS.send(...)` in `run()`'s `finally` block. --- ##### Was generative AI tooling used to co-author this PR? - [ ] Yes (please specify the tool below) Generated-by: Claude Code following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) -- 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]
