[
https://issues.apache.org/jira/browse/BEAM-3837?focusedWorklogId=197459&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-197459
]
ASF GitHub Bot logged work on BEAM-3837:
----------------------------------------
Author: ASF GitHub Bot
Created on: 12/Feb/19 10:02
Start Date: 12/Feb/19 10:02
Worklog Time Spent: 10m
Work Description: mxm commented on pull request #7801: [BEAM-3837] More
complete test for try-split.
URL: https://github.com/apache/beam/pull/7801#discussion_r255877577
##########
File path: sdks/python/apache_beam/runners/portability/fn_api_runner.py
##########
@@ -1119,20 +1124,41 @@ def __init__(self, provision_info=None,
artifact_staging_dir=None):
self.artifact_staging_dir = artifact_staging_dir
+_split_managers = []
+
+
+@contextlib.contextmanager
+def split_manager(stage_name, split_manager):
+ """Registers a split manager to control the flow of elements to a given
stage.
+
+ Used for testing.
Review comment:
Since this is integrated into the main code anyways, probably not worthwhile.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on 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
Issue Time Tracking
-------------------
Worklog Id: (was: 197459)
Time Spent: 1h 40m (was: 1.5h)
> Python SDK harness should understand a BundleSplitRequest and respond with a
> BundleSplit before bundle finishes
> ---------------------------------------------------------------------------------------------------------------
>
> Key: BEAM-3837
> URL: https://issues.apache.org/jira/browse/BEAM-3837
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-harness
> Reporter: Eugene Kirpichov
> Assignee: Chamikara Jayalath
> Priority: Major
> Labels: triaged
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
> Like BEAM-3836 but for Python SDK harness.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
