Repository: beam Updated Branches: refs/heads/master c6c8d9ee6 -> 2304972c5
[BEAM-1348] Fix type error introduced into Python SDK because of PR/3268 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/595ca1ec Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/595ca1ec Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/595ca1ec Branch: refs/heads/master Commit: 595ca1ec84134328be5be3c8ae21a5a43a5a7166 Parents: c6c8d9e Author: Luke Cwik <lc...@google.com> Authored: Mon Jun 19 15:48:06 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Mon Jun 19 15:48:06 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/portability/fn_api_runner.py | 2 +- sdks/python/apache_beam/runners/worker/sdk_worker.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/595ca1ec/sdks/python/apache_beam/runners/portability/fn_api_runner.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner.py b/sdks/python/apache_beam/runners/portability/fn_api_runner.py index 90764f4..d792131 100644 --- a/sdks/python/apache_beam/runners/portability/fn_api_runner.py +++ b/sdks/python/apache_beam/runners/portability/fn_api_runner.py @@ -264,7 +264,7 @@ class FnApiRunner(maptask_executor_runner.MapTaskExecutorRunner): element_coder.get_impl().encode_to_stream( element, output_stream, True) elements_data = output_stream.get() - state_key = beam_fn_api_pb2.StateKey(key=view_id) + state_key = beam_fn_api_pb2.StateKey.MultimapSideInput(key=view_id) state_handler.Clear(state_key) state_handler.Append(state_key, elements_data) http://git-wip-us.apache.org/repos/asf/beam/blob/595ca1ec/sdks/python/apache_beam/runners/worker/sdk_worker.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker.py b/sdks/python/apache_beam/runners/worker/sdk_worker.py index f662538..d08b179 100644 --- a/sdks/python/apache_beam/runners/worker/sdk_worker.py +++ b/sdks/python/apache_beam/runners/worker/sdk_worker.py @@ -358,7 +358,7 @@ class SdkWorker(object): tag=tag, source=SideInputSource( self.state_handler, - beam_fn_api_pb2.StateKey( + beam_fn_api_pb2.StateKey.MultimapSideInput( key=si.view_fn.id.encode('utf-8')), coder=unpack_and_deserialize_py_fn(si.view_fn))) output_tags = list(transform.outputs.keys())
