You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/05/02 03:23:33 UTC
[1/2] beam git commit: maptask_executor_runner_test: build fix
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 <dh...@google.com>
Authored: Mon May 1 20:16:03 2017 -0700
Committer: Dan Halperin <dh...@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(
[2/2] beam git commit: This closes #2815
Posted by dh...@apache.org.
This closes #2815
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7fa00647
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7fa00647
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7fa00647
Branch: refs/heads/master
Commit: 7fa00647d5506281f456b4b9974ee9efc7484dba
Parents: 034565c 47569f5
Author: Dan Halperin <dh...@google.com>
Authored: Mon May 1 20:18:44 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon May 1 20:18:44 2017 -0700
----------------------------------------------------------------------
.../runners/portability/maptask_executor_runner_test.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------