Repository: beam Updated Branches: refs/heads/master e0e39a975 -> 80d2548f2
enable test_multi_valued_singleton_side_input test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a3a15a53 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a3a15a53 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a3a15a53 Branch: refs/heads/master Commit: a3a15a5370467db72f8be2fa031483349e49f6ab Parents: e0e39a9 Author: Ahmet Altay <al...@google.com> Authored: Fri Apr 7 17:54:14 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Mon Apr 10 10:49:12 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/transforms/sideinputs_test.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a3a15a53/sdks/python/apache_beam/transforms/sideinputs_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/transforms/sideinputs_test.py b/sdks/python/apache_beam/transforms/sideinputs_test.py index 53669de..bf9aeff 100644 --- a/sdks/python/apache_beam/transforms/sideinputs_test.py +++ b/sdks/python/apache_beam/transforms/sideinputs_test.py @@ -145,16 +145,14 @@ class SideInputsTest(unittest.TestCase): assert_that(result, equal_to([(1, 'empty'), (2, 'empty')])) pipeline.run() - # @attr('ValidatesRunner') - # TODO(BEAM-1124): Temporarily disable it due to test failed running on - # Dataflow service. + @attr('ValidatesRunner') def test_multi_valued_singleton_side_input(self): pipeline = self.create_pipeline() pcol = pipeline | 'start' >> beam.Create([1, 2]) side = pipeline | 'side' >> beam.Create([3, 4]) # 2 values in side input. pcol | 'compute' >> beam.FlatMap( # pylint: disable=expression-not-assigned lambda x, s: [x * s], beam.pvalue.AsSingleton(side)) - with self.assertRaises(ValueError): + with self.assertRaises(Exception): pipeline.run() @attr('ValidatesRunner')
