This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch aaltay-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 99570f4a315608b7f3d9bed662ffad3e0b630dfc Author: Ahmet Altay <[email protected]> AuthorDate: Fri May 14 15:48:05 2021 -0700 Update test_error_message_includes_stage test --- .../apache_beam/runners/portability/fn_api_runner/fn_runner_test.py | 4 ++++ 1 file changed, 4 insertions(+) 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 2ac9c42..abe025c 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 @@ -823,11 +823,15 @@ 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):
