Repository: beam Updated Branches: refs/heads/master 034565c68 -> 7fa00647d
maptask_executor_runner_test: build fix OutputValue was renamed to TaggedOutput in #2810, but this was missed or merge conflicted. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/47569f56 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/47569f56 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/47569f56 Branch: refs/heads/master Commit: 47569f56cc795a5068e8eadfcb1c34cddf9829db Parents: 034565c Author: Dan Halperin <dhalp...@google.com> Authored: Mon May 1 20:16:03 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon May 1 20:16:03 2017 -0700 ---------------------------------------------------------------------- .../runners/portability/maptask_executor_runner_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/47569f56/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py b/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py index 6e13e73..b52c73c 100644 --- a/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py @@ -102,7 +102,7 @@ class MapTaskExecutorRunnerTest(unittest.TestCase): def tee(elem, *tags): for tag in tags: if tag in elem: - yield beam.pvalue.OutputValue(tag, elem) + yield beam.pvalue.TaggedOutput(tag, elem) with self.create_pipeline() as p: xy = (p | 'Create' >> beam.Create(['x', 'y', 'xy']) @@ -113,7 +113,7 @@ class MapTaskExecutorRunnerTest(unittest.TestCase): def test_pardo_side_and_main_outputs(self): def even_odd(elem): yield elem - yield beam.pvalue.OutputValue('odd' if elem % 2 else 'even', elem) + yield beam.pvalue.TaggedOutput('odd' if elem % 2 else 'even', elem) with self.create_pipeline() as p: ints = p | beam.Create([1, 2, 3]) named = ints | 'named' >> beam.FlatMap(