pabloem commented on issue #11229: [BEAM-9608] Increasing scope of context managers for FnApiRunner URL: https://github.com/apache/beam/pull/11229#issuecomment-604139704 r: @robertwb I've added two classes under `execution`: - `FnApiExecutionContext`, which manages runner-related context utilities and variables, like intermediate pcollection buffers, worker handler manager, safe coders and pipeline context. - `BundleContextManager`, which manages bundle-exeecution-related utilities and variables, such as the process bundle descriptor, the worker handlers for that stage, and the callbacks for get_buffer and get_coder_impl. This change increases their scope to manage iterable_state_write, and worker handlers. The goal in the future (streaming) is for `FnApiExecutionContext` to manage a watermark manager.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
