This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch revert-14819-aaltay-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 279227012c7d7a35f7ea400b200e8df9cb15fa3f Author: Ahmet Altay <[email protected]> AuthorDate: Mon Jun 28 12:58:50 2021 -0700 Revert "Update test_error_message_includes_stage test" --- .../apache_beam/runners/portability/fn_api_runner/fn_runner_test.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py index 8074759..4053b9c 100644 --- a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py @@ -825,15 +825,11 @@ class FnApiRunnerTest(unittest.TestCase): | beam.Create(['a', 'b']) | 'StageA' >> beam.Map(lambda x: x) | 'StageB' >> beam.Map(lambda x: x) - | 'FusionBreakBeforeRaise' >> beam.Reshuffle() | 'StageC' >> beam.Map(raise_error) - | 'FusionBreakAfterRaise' >> beam.Reshuffle() | 'StageD' >> beam.Map(lambda x: x)) message = e_cm.exception.args[0] self.assertIn('StageC', message) - self.assertNotIn('StageA', message) self.assertNotIn('StageB', message) - self.assertNotIn('StageD', message) def test_error_traceback_includes_user_code(self): def first(x):
