ephraimbuddy opened a new pull request, #73290: URL: https://github.com/apache/airflow/pull/73290
Task supervision and Dag processing duplicate their message dispatch logic. Move dispatch to `WatchedSubprocess`, with an explicit supported message set for each subprocess and common requests delegated to `request_handlers.py`. Preserve existing wire responses, error categories, serialization options, and process-specific behavior. Typed registration checks message/handler compatibility, method lookup honors overrides, and an explicit sentinel marks responses already sent. Add parity tests for the exact supported message sets and shared handler reuse, alongside dispatch regression tests and negative typing cases. This is a narrower alternative to #68106, with the same goal of sharing dispatch. --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Codex (GPT-6) Generated-by: Codex (GPT-6) 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]
