[
https://issues.apache.org/jira/browse/BEAM-9608?focusedWorklogId=409957&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-409957
]
ASF GitHub Bot logged work on BEAM-9608:
----------------------------------------
Author: ASF GitHub Bot
Created on: 25/Mar/20 23:20
Start Date: 25/Mar/20 23:20
Worklog Time Spent: 10m
Work Description: 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:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 409957)
Time Spent: 50m (was: 40m)
> Add context managers for FnApiRunner to manage execution of each bundle
> -----------------------------------------------------------------------
>
> Key: BEAM-9608
> URL: https://issues.apache.org/jira/browse/BEAM-9608
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
> Reporter: Pablo Estrada
> Assignee: Pablo Estrada
> Priority: Major
> Time Spent: 50m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)