You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/07/23 23:47:12 UTC
[06/12] incubator-beam git commit: fix pipeline test
fix pipeline test
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/362f2e9e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/362f2e9e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/362f2e9e
Branch: refs/heads/python-sdk
Commit: 362f2e9e4398662d55a2a4e6399f43155c58ed24
Parents: 0183051
Author: Ahmet Altay <al...@google.com>
Authored: Fri Jul 22 16:03:08 2016 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Sat Jul 23 16:43:46 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/pipeline_test.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/362f2e9e/sdks/python/apache_beam/pipeline_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/pipeline_test.py b/sdks/python/apache_beam/pipeline_test.py
index 39816c0..327f26c 100644
--- a/sdks/python/apache_beam/pipeline_test.py
+++ b/sdks/python/apache_beam/pipeline_test.py
@@ -183,7 +183,7 @@ class PipelineTest(unittest.TestCase):
self.assertEqual(
['a-x', 'b-x', 'c-x'],
- sorted(['a', 'b', 'c'] | '-x' >> AddSuffix()))
+ sorted(['a', 'b', 'c'] | 'AddSuffix' >> AddSuffix('-x')))
def test_cached_pvalues_are_refcounted(self):
"""Test that cached PValues are refcounted and deleted.
@@ -218,7 +218,7 @@ class PipelineTest(unittest.TestCase):
biglist
| 'oom:addone' >> Map(lambda x: (x, 1))
| 'oom:dupes' >> FlatMap(create_dupes,
- AsIter(biglist)).with_outputs('side', main='main'))
+ AsIter(biglist)).with_outputs('side', main='main'))
result = (
(dupes.side, dupes.main, dupes.side)
| 'oom:flatten' >> Flatten()
@@ -232,8 +232,8 @@ class PipelineTest(unittest.TestCase):
{
'oom:flatten': 3 * num_elements,
('oom:combine/GroupByKey/reify_windows', None): 3 * num_elements,
- ('oom:dupes/oom:dupes', 'side'): num_elements,
- ('oom:dupes/oom:dupes', None): num_elements,
+ ('oom:dupes/FlatMap(create_dupes)', 'side'): num_elements,
+ ('oom:dupes/FlatMap(create_dupes)', None): num_elements,
'oom:create': num_elements,
('oom:addone', None): num_elements,
'oom:combine/GroupByKey/group_by_key': 1,