beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] beam git commit: maptask_executor_runner_test: build fix
Date Tue, 02 May 2017 03:23:33 GMT
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 <dhalperi@google.com>
Authored: Mon May 1 20:16:03 2017 -0700
Committer: Dan Halperin <dhalperi@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(


Mime
View raw message