seanghaeli opened a new pull request, #66611: URL: https://github.com/apache/airflow/pull/66611
Add read-only XCom access to the callback supervisor IPC channel, allowing callbacks to fetch XCom values from upstream tasks via the same mechanism used for Connections and Variables. ## Motivation PR #65269 added Connection, Variable, and MaskSecret comms channels to the callback supervisor. XCom was deferred because it requires explicit dag_id, run_id, and task_id (callbacks have no implicit task context). This PR adds that missing piece. ## Changes - Add `GetXCom` to the `CallbackToSupervisor` union type - Add `handle_get_xcom` shared handler in `request_handlers.py` - Route `GetXCom` messages in `CallbackSubprocess._handle_request` - Add tests for both basic XCom fetch and fetch with map_index/include_prior_dates Only read access (GetXCom) is exposed. SetXCom and DeleteXCom remain out of scope for callbacks since they should not be producing XCom values. related: #65269 --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Claude Code (Opus 4.6) Generated-by: Claude Code (Opus 4.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]
