beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [6/7] beam git commit: Adapt to PR #2505 changes to protos.
Date Mon, 24 Apr 2017 21:52:50 GMT
Adapt to PR #2505 changes to protos.


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/488f3c67
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/488f3c67
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/488f3c67

Branch: refs/heads/master
Commit: 488f3c6730edd4a22005132f5d8c819fa2deb3a1
Parents: fbeb7e1
Author: Robert Bradshaw <robertwb@gmail.com>
Authored: Fri Apr 21 14:22:07 2017 -0700
Committer: Robert Bradshaw <robertwb@gmail.com>
Committed: Mon Apr 24 14:52:28 2017 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/pipeline.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/488f3c67/sdks/python/apache_beam/pipeline.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/pipeline.py b/sdks/python/apache_beam/pipeline.py
index 8e811bc..0f4c8db 100644
--- a/sdks/python/apache_beam/pipeline.py
+++ b/sdks/python/apache_beam/pipeline.py
@@ -336,7 +336,7 @@ class Pipeline(object):
     # argument evaluation order.
     root_transform_id = context.transforms.get_id(self._root_transform())
     proto = beam_runner_api_pb2.Pipeline(
-        root_transform_id=root_transform_id,
+        root_transform_ids=[root_transform_id],
         components=context.to_runner_api())
     return proto
 
@@ -345,8 +345,9 @@ class Pipeline(object):
     p = Pipeline(runner=runner, options=options)
     from apache_beam.runners import pipeline_context
     context = pipeline_context.PipelineContext(proto.components)
+    root_transform_id, = proto.root_transform_ids
     p.transforms_stack = [
-        context.transforms.get_by_id(proto.root_transform_id)]
+        context.transforms.get_by_id(root_transform_id)]
     # TODO(robertwb): These are only needed to continue construction. Omit?
     p.applied_labels = set([
         t.unique_name for t in proto.components.transforms.values()])


Mime
View raw message