Repository: incubator-beam Updated Branches: refs/heads/python-sdk 39dda320a -> 73168b220
Remove ptransform tests from the excluded tests list This will enable ptransform_test as part of the pre-commit 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/2fc45b4c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2fc45b4c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2fc45b4c Branch: refs/heads/python-sdk Commit: 2fc45b4c6f08f5437312d0cd1acfc1a5187a3d7a Parents: 39dda32 Author: Ahmet Altay <[email protected]> Authored: Sat Jul 9 15:08:45 2016 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Mon Jul 11 13:51:50 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/transforms/ptransform_test.py | 9 ++++----- sdks/python/setup.cfg | 2 +- 2 files changed, 5 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2fc45b4c/sdks/python/apache_beam/transforms/ptransform_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/transforms/ptransform_test.py b/sdks/python/apache_beam/transforms/ptransform_test.py index aedb384..feb081c 100644 --- a/sdks/python/apache_beam/transforms/ptransform_test.py +++ b/sdks/python/apache_beam/transforms/ptransform_test.py @@ -461,9 +461,8 @@ class PTransformTest(unittest.TestCase): self.assertStartswith( e.exception.message, - 'Runtime type violation detected within ' - 'ParDo(D/reify_windows): Input to GroupByKey must be ' - 'a PCollection with elements compatible with KV[A, B]') + 'Input type hint violation at D: expected ' + 'Tuple[TypeVariable[K], TypeVariable[V]]') def test_group_by_key_only_input_must_be_kv_pairs(self): pipeline = Pipeline('DirectPipelineRunner') @@ -472,8 +471,8 @@ class PTransformTest(unittest.TestCase): pcolls | beam.GroupByKeyOnly('D') pipeline.run() - expected_error_prefix = ('Input to GroupByKeyOnly must be a PCollection of ' - 'windowed key-value pairs.') + expected_error_prefix = ('Input type hint violation at D: expected ' + 'Tuple[TypeVariable[K], TypeVariable[V]]') self.assertStartswith(cm.exception.message, expected_error_prefix) def test_keys_and_values(self): http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2fc45b4c/sdks/python/setup.cfg ---------------------------------------------------------------------- diff --git a/sdks/python/setup.cfg b/sdks/python/setup.cfg index 5b58e8d..317121f 100644 --- a/sdks/python/setup.cfg +++ b/sdks/python/setup.cfg @@ -34,5 +34,5 @@ verbosity=2 # # The batchworker_test is excluded because it imports batchworker.py which # in-turn tries to import module 'resource' which does not work for Windows. -exclude=examples|bigquery_test|ptransform_test|fast_coders_test|typecoders_test|workitem_test|executor_test|streamingworker_test|batchworker_test +exclude=examples|bigquery_test|fast_coders_test|typecoders_test|workitem_test|executor_test|streamingworker_test|batchworker_test
