angoenka commented on issue #11071: [BEAM-9465] Fire repeatedly in reshuffle URL: https://github.com/apache/beam/pull/11071#issuecomment-596845610 Failure seems to be unrelated: AssertionError: "Failed assert" does not match "Unexpected type for Value message." Stacktrace self = <apache_beam.runners.portability.portable_runner_test.PortableRunnerTestWithExternalEnv testMethod=test_assert_that> def test_assert_that(self): # TODO: figure out a way for fn_api_runner to parse and raise the # underlying exception. with self.assertRaisesRegex(Exception, 'Failed assert'): with self.create_pipeline() as p: > assert_that(p | beam.Create(['a', 'b']), equal_to(['a'])) E AssertionError: "Failed assert" does not match "Unexpected type for Value message." apache_beam/runners/portability/fn_api_runner_test.py:105: AssertionError
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
