jason810496 opened a new pull request, #67175: URL: https://github.com/apache/airflow/pull/67175
- related: https://github.com/apache/airflow/pull/65958 ### Why Extract the `selector_loop` modularization from https://github.com/apache/airflow/pull/65958 PR for further reusability and enhance the type annotation. This improvement should not be blocked by the AIP-108 vote. ### What Pull the buffered socket reader and the selector dispatch loop out of ``WatchedSubprocess`` into ``airflow.sdk.execution_time.selector_loop``, together with a new ``make_raw_forwarder`` helper. ``WatchedSubprocess`` now delegates its event loop to ``service_selector`` and imports ``make_buffered_socket_reader`` from the shared module, so the same primitives can back other selector-driven bridges without copy/paste. The behavior should be unchanged after this refactor. --- ##### Was generative AI tooling used to co-author this PR? - [x] Yes, with help of Claude Code Opus 4.7 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]
