andreahlert commented on PR #61627: URL: https://github.com/apache/airflow/pull/61627#issuecomment-4562340332
Rebased onto current `main` after the Coordinator Layer refactor ([#65958](https://github.com/apache/airflow/pull/65958)) moved `process.wait()` out of `supervise_task()` and into `_PythonCoordinator.execute_task()`. Squashed the branch into a single commit and relocated the signal-forwarding handler from `supervise_task()` to `ActivitySubprocess.wait()`, which is now where the subprocess is waited on and where `self.pid` is available. Confirmed the underlying bug still reproduces on plain `main` (test hangs and the supervisor process dies on the operator-issued SIGTERM without forwarding it). With the new placement the test passes in ~3s, and the 19 existing signal-related tests in `test_supervisor.py` still pass. @kaxil PTAL when you have a moment. --- Drafted-by: Claude Code (Opus 4.7); reviewed by @andreahlert before posting -- 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]
