This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 08161984d05836da2dee1166f5d9f35c6b8d6ee8
Merge: 403360c fefab67
Author: Pablo <pabl...@users.noreply.github.com>
AuthorDate: Tue Sep 25 13:23:35 2018 -0700
Merge pull request #6418 from qinyeli/display_bug
[BEAM-5501] Interactive Beam -- display issue: number of PTransform
executed wrongly displayed
.../runners/interactive/display/display_manager.py | 39 ++++++-------
.../display/interactive_pipeline_graph.py | 13 +++--
.../runners/interactive/display/pipeline_graph.py | 2 +-
.../runners/interactive/interactive_runner.py | 11 +---
.../runners/interactive/pipeline_analyzer.py | 64 ++++++++++++++++------
.../runners/interactive/pipeline_analyzer_test.py | 13 +++--
6 files changed, 84 insertions(+), 58 deletions(-)
diff --cc sdks/python/apache_beam/runners/interactive/pipeline_analyzer.py
index b0cf134,1b63975..1ac67ac
--- a/sdks/python/apache_beam/runners/interactive/pipeline_analyzer.py
+++ b/sdks/python/apache_beam/runners/interactive/pipeline_analyzer.py
@@@ -116,12 -121,12 +121,12 @@@ class PipelineAnalyzer(object)
sample=True)
required_transforms['_root'] = beam_runner_api_pb2.PTransform(
- subtransforms=top_level_required_transforms.keys())
+ subtransforms=list(top_level_required_transforms.keys()))
- referenced_pcollection_ids = self._referenced_pcollection_ids(
+ referenced_pcoll_ids = self._referenced_pcoll_ids(
required_transforms)
referenced_pcollections = {}
- for pcoll_id in referenced_pcollection_ids:
+ for pcoll_id in referenced_pcoll_ids:
obj = self._context.pcollections.get_by_id(pcoll_id)
proto = self._context.pcollections.get_proto(obj)
referenced_pcollections[pcoll_id] = proto
