TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)
>   key, unused_value = windowed_value.value
E   TypeError: 'int' object is not iterable

apache_beam/runners/common.py:1015: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   raise ValueError((
        'Input value to a stateful DoFn or KeyParam must be a KV tuple; '
        'instead, got \'%s\'.') % (windowed_value.value, ))
E   ValueError: Input value to a stateful DoFn or KeyParam must be a KV tuple; instead, got '1'.

apache_beam/runners/common.py:1017: ValueError

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.common_test.DoFnProcessTest testMethod=test_dofn_process_keyparam_error_no_key>

    def test_dofn_process_keyparam_error_no_key(self):
      class DoFnProcessWithKeyparam(DoFn):
        def process(self, element, mykey=DoFn.KeyParam):
          yield "{key}-verify".format(key=mykey)
    
      pipeline_options = PipelineOptions()
      with self.assertRaises(ValueError),\
           TestPipeline(options=pipeline_options) as p:
        test_stream = (TestStream().advance_watermark_to(10).add_elements([1, 2]))
>       (p | test_stream | beam.ParDo(DoFnProcessWithKeyparam()))

apache_beam/runners/common_test.py:158: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/pipeline.py:620: in __exit__
    self.result = self.run()
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/test_pipeline.py:119: in run
    state = result.wait_until_finish()
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/direct_runner.py:655: in wait_until_finish
    self._executor.await_completion()
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/executor.py:418: in await_completion
    self._executor.await_completion()
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/executor.py:465: in await_completion
    raise update.exception
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/executor.py:356: in call
    self.attempt_call(
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/executor.py:399: in attempt_call
    evaluator.process_element(value)
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/direct/transform_evaluator.py:875: in process_element
    self.runner.process(element)
apache_beam/runners/common.py:1498: in apache_beam.runners.common.DoFnRunner.process
    def process(self, windowed_value):
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1061: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = [b'']
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x7f4ba824b160>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == [b''], unexpected elements [b''], missing elements ['a']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:
Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 917, in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
  File "apache_beam/runners/common.py", line 1061, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2084, in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py", line 192, in _equal
    raise BeamAssertException(msg)
apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == [b''], unexpected elements [b''], missing elements ['a']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.trivial_runner_test.TrivialRunnerTest testMethod=test_assert_that>

    def test_assert_that(self):
      # If this fails, the other tests may be vacuous.
      with self.assertRaisesRegex(Exception, 'Failed assert'):
        with beam.Pipeline(runner=TrivialRunner()) as p:
>         assert_that(p | beam.Impulse(), equal_to(['a']))
E         AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

apache_beam/runners/trivial_runner_test.py:38: AssertionError

AssertionError: 'StageC' not found in 'Pipeline job-63f4e1d7-ea51-4d44-922d-a94aeeb20324 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1398, in process_bundle\n    raise RuntimeError(result.error)\nRuntimeError: Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'
self = <apache_beam.runners.portability.portable_runner_test.PortableRunnerTestWithExternalEnv testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Pipeline job-63f4e1d7-ea51-4d44-922d-a94aeeb20324 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1398, in process_bundle\n    raise RuntimeError(result.error)\nRuntimeError: Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Pipeline job-159daf7a-ad8a-4957-8a03-e06cdf681bc8 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'
self = <apache_beam.runners.portability.portable_runner_test.PortableRunnerTest testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Pipeline job-159daf7a-ad8a-4957-8a03-e06cdf681bc8 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Pipeline job-6a248d3e-567b-4024-bee5-32030cd5c3fa failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'
self = <apache_beam.runners.portability.portable_runner_test.PortableRunnerOptimizedWithoutFusion testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Pipeline job-6a248d3e-567b-4024-bee5-32030cd5c3fa failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1061: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = ['a', 'b']
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x799069245ca0>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:
Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 917, in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
  File "apache_beam/runners/common.py", line 1061, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2084, in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py", line 192, in _equal
    raise BeamAssertException(msg)
apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTest 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 "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:114: AssertionError

AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTest testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Pipeline job-3c7e9b46-f87d-4082-a30b-16ad0b548520 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'
self = <apache_beam.runners.portability.portable_runner_test.PortableRunnerTestWithLocalDocker testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Pipeline job-3c7e9b46-f87d-4082-a30b-16ad0b548520 failed in state FAILED: Error running pipeline.\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 294, in _run_job\n    self.result = self._invoke_runner()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/local_job_service.py", line 316, in _invoke_runner\n    return fn_runner.FnApiRunner(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 221, in run_via_runner_api\n    return self.run_stages(stage_context, stages)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 468, in run_stages\n    bundle_results = self._execute_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 793, in _execute_bundle\n    self._run_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1032, in _run_bundle\n    result, splits = bundle_manager.process_bundle(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py", line 1358, in process_bundle\n    result_future = self._worker_handler.control_conn.push(process_bundle_req)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py", line 386, in push\n    response = self.worker.do_instruction(request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpc testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithDisabledCaching testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1061: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = ['a', 'b']
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x7990481fa790>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:
Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 917, in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
  File "apache_beam/runners/common.py", line 1061, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2084, in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py", line 192, in _equal
    raise BeamAssertException(msg)
apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithMultiWorkers 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 "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:114: AssertionError

AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithMultiWorkers testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in 'Traceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 690, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    windowed_value, self.process_method(windowed_value.value))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2086, in <lambda>\n    wrapper = lambda x: [fn(x)]\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py", line 1161, in raise_error\n    raise RuntimeError(\nRuntimeError: This error is expected and does not indicate a test failure.\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process\n    return self.do_fn_invoker.invoke_process(windowed_value)\n  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process\n    self.output_handler.handle_process_outputs(\n  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs\n    self._write_value_to_tag(tag, windowed_value, watermark_estimator)\n  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag\n    self.main_receivers.receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n\nDuring handling of the above exception, another exception occurred:\n\nTraceback (most recent call last):\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 311, in _execute\n    response = task()\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 386, in <lambda>\n    lambda: self.create_worker().do_instruction(request), request)\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 656, in do_instruction\n    return getattr(self, request_type)(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/sdk_worker.py", line 694, in process_bundle\n    bundle_processor.process_bundle(instruction_id))\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1274, in process_bundle\n    input_op_by_transform_id[element.transform_id].process_encoded(\n  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py", line 237, in process_encoded\n    self.output(decoded_value)\n  File "apache_beam/runners/worker/operations.py", line 567, in apache_beam.runners.worker.operations.Operation.output\n    def output(self, windowed_value, output_index=0):\n  File "apache_beam/runners/worker/operations.py", line 569, in apache_beam.runners.worker.operations.Operation.output\n    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 260, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    def receive(self, windowed_value):\n  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive\n    self.consumer.process(windowed_value)\n  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process\n    with self.scoped_process_state:\n  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process\n    delayed_applications = self.dofn_runner.process(o)\n  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process\n    self._reraise_augmented(exn, windowed_value)\n  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented\n    self._maybe_sample_exception(exc_info, windowed_value)\nTypeError: Argument \'exn\' has incorrect type (expected BaseException, got tuple)\n'

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithBundleRepeat testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1061: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = ['a', 'b']
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x7aab10bee700>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:
Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 917, in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
  File "apache_beam/runners/common.py", line 1061, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2084, in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py", line 192, in _equal
    raise BeamAssertException(msg)
apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['a', 'b'], unexpected elements ['b']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithBundleRepeat 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 "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:114: AssertionError

AssertionError: "Failed assert" does not match "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:917: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1061: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py:2084: in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

actual = ['b', 'a']
equals_fn = <function equal_to.<locals>._equal.<locals>.<lambda> at 0x7f4b806ed430>

    def _equal(actual, equals_fn=equals_fn):
      expected_list = list(expected)
    
      # Try to compare actual and expected by sorting. This fails with a
      # TypeError in Python 3 if different types are present in the same
      # collection. It can also raise false negatives for types that don't have
      # a deterministic sort order, like pyarrow Tables as of 0.14.1
      if not equals_fn:
        equals_fn = lambda e, a: e == a
        try:
          sorted_expected = sorted(expected)
          sorted_actual = sorted(actual)
          if sorted_expected == sorted_actual:
            return
        except TypeError:
          pass
      # Slower method, used in two cases:
      # 1) If sorted expected != actual, use this method to verify the inequality.
      #    This ensures we don't raise any false negatives for types that don't
      #    have a deterministic sort order.
      # 2) As a fallback if we encounter a TypeError in python 3. this method
      #    works on collections that have different types.
      unexpected = []
      for element in actual:
        found = False
        for i, v in enumerate(expected_list):
          if equals_fn(v, element):
            found = True
            expected_list.pop(i)
            break
        if not found:
          unexpected.append(element)
      if unexpected or expected_list:
        msg = 'Failed assert: %r == %r' % (expected, actual)
        if unexpected:
          msg = msg + ', unexpected elements %r' % unexpected
        if expected_list:
          msg = msg + ', missing elements %r' % expected_list
>       raise BeamAssertException(msg)
E       apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['b', 'a'], unexpected elements ['b']

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py:192: BeamAssertException

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:

>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:689: in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
apache_beam/runners/common.py:1687: in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
apache_beam/runners/common.py:1800: in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

During handling of the above exception, another exception occurred:
Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 917, in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
  File "apache_beam/runners/common.py", line 1061, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/transforms/core.py", line 2084, in <lambda>
    wrapper = lambda x, *args, **kwargs: [fn(x, *args, **kwargs)]
  File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py39/build/srcs/sdks/python/target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/testing/util.py", line 192, in _equal
    raise BeamAssertException(msg)
apache_beam.testing.util.BeamAssertException: Failed assert: ['a'] == ['b', 'a'], unexpected elements ['b']

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "apache_beam/runners/common.py", line 1501, in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 689, in apache_beam.runners.common.SimpleInvoker.invoke_process
    self.output_handler.handle_process_outputs(
  File "apache_beam/runners/common.py", line 1687, in apache_beam.runners.common._OutputHandler.handle_process_outputs
    self._write_value_to_tag(tag, windowed_value, watermark_estimator)
  File "apache_beam/runners/common.py", line 1800, in apache_beam.runners.common._OutputHandler._write_value_to_tag
    self.main_receivers.receive(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 263, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
  File "apache_beam/runners/worker/operations.py", line 950, in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
  File "apache_beam/runners/worker/operations.py", line 951, in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
  File "apache_beam/runners/common.py", line 1503, in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
  File "apache_beam/runners/common.py", line 1611, in apache_beam.runners.common.DoFnRunner._reraise_augmented
    self._maybe_sample_exception(exc_info, windowed_value)
TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithBundleRepeatAndMultiWorkers 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 "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:114: AssertionError

AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"
self = <apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithBundleRepeatAndMultiWorkers testMethod=test_error_message_includes_stage>

    def test_error_message_includes_stage(self):
      with self.assertRaises(BaseException) as e_cm:
        with self.create_pipeline() as p:
    
          def raise_error(x):
            raise RuntimeError(
                'This error is expected and does not indicate a test failure.')
    
          # pylint: disable=expression-not-assigned
          (
              p
              | beam.Create(['a', 'b'])
              | 'StageA' >> beam.Map(lambda x: x)
              | 'StageB' >> beam.Map(lambda x: x)
              | 'StageC' >> beam.Map(raise_error)
              | 'StageD' >> beam.Map(lambda x: x))
      message = e_cm.exception.args[0]
>     self.assertIn('StageC', message)
E     AssertionError: 'StageC' not found in "Argument 'exn' has incorrect type (expected BaseException, got tuple)"

target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:1173: AssertionError

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)
>   return self.do_fn_invoker.invoke_process(windowed_value)

apache_beam/runners/common.py:1501: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/common.py:690: in apache_beam.runners.common.SimpleInvoker.invoke_process
    windowed_value, self.process_method(windowed_value.value))
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.worker.log_handler_test.RaiseException object at 0x7f4ba1f8d820>
_ = b'hello, world!'

    def process(self, _):
>     raise RuntimeError(self.msg)
E     RuntimeError: expected exception

apache_beam/runners/worker/log_handler_test.py:56: RuntimeError

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.worker.bundle_processor_test.DataSamplingTest testMethod=test_can_sample_exceptions>

    def test_can_sample_exceptions(self):
      """Test that exceptions are sampled."""
      data_sampler = DataSampler(sample_every_sec=0.1)
      descriptor = beam_fn_api_pb2.ProcessBundleDescriptor()
    
      # Boiler plate for the DoFn.
      WINDOWING_ID = 'window'
      WINDOW_CODER_ID = 'cw'
      window = descriptor.windowing_strategies[WINDOWING_ID]
      window.window_fn.urn = common_urns.global_windows.urn
      window.window_coder_id = WINDOW_CODER_ID
      window.trigger.default.SetInParent()
      window_coder = descriptor.coders[WINDOW_CODER_ID]
      window_coder.spec.urn = common_urns.StandardCoders.Enum.GLOBAL_WINDOW.urn
    
      # Input collection to the exception raising DoFn.
      INPUT_PCOLLECTION_ID = 'pc-in'
      INPUT_CODER_ID = 'c-in'
      descriptor.pcollections[
          INPUT_PCOLLECTION_ID].unique_name = INPUT_PCOLLECTION_ID
      descriptor.pcollections[INPUT_PCOLLECTION_ID].coder_id = INPUT_CODER_ID
      descriptor.pcollections[
          INPUT_PCOLLECTION_ID].windowing_strategy_id = WINDOWING_ID
      descriptor.coders[
          INPUT_CODER_ID].spec.urn = common_urns.StandardCoders.Enum.BYTES.urn
    
      # Output collection to the exception raising DoFn. Because the transform
      # "failed" to process the input element, we do NOT expect to see a sample in
      # this PCollection.
      OUTPUT_PCOLLECTION_ID = 'pc-out'
      OUTPUT_CODER_ID = 'c-out'
      descriptor.pcollections[
          OUTPUT_PCOLLECTION_ID].unique_name = OUTPUT_PCOLLECTION_ID
      descriptor.pcollections[OUTPUT_PCOLLECTION_ID].coder_id = OUTPUT_CODER_ID
      descriptor.pcollections[
          OUTPUT_PCOLLECTION_ID].windowing_strategy_id = WINDOWING_ID
      descriptor.coders[
          OUTPUT_CODER_ID].spec.urn = common_urns.StandardCoders.Enum.BYTES.urn
    
      # Add a simple transform to inject an element into the data sampler. This
      # doesn't use the FnApi, so this uses a simple operation to forward its
      # payload to consumers.
      TEST_OP_TRANSFORM_ID = 'test_op'
      test_transform = descriptor.transforms[TEST_OP_TRANSFORM_ID]
      test_transform.outputs['None'] = INPUT_PCOLLECTION_ID
      test_transform.spec.urn = 'beam:internal:testop:v1'
      test_transform.spec.payload = b'hello, world!'
    
      # Add the DoFn to create an exception to sample from.
      TEST_EXCEPTION_TRANSFORM_ID = 'test_transform'
      test_transform = descriptor.transforms[TEST_EXCEPTION_TRANSFORM_ID]
      test_transform.inputs['0'] = INPUT_PCOLLECTION_ID
      test_transform.outputs['None'] = OUTPUT_PCOLLECTION_ID
      test_transform.spec.urn = 'beam:internal:testexn:v1'
      test_transform.spec.payload = b'expected exception'
    
      try:
        # Create and process a fake bundle. The instruction id doesn't matter
        # here.
        processor = BundleProcessor(
            set(), descriptor, None, None, data_sampler=data_sampler)
    
        with self.assertRaisesRegex(RuntimeError, 'expected exception'):
>         processor.process_bundle('instruction_id')

apache_beam/runners/worker/bundle_processor_test.py:390: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py:1227: in process_bundle
    op.start()
apache_beam/runners/worker/log_handler_test.py:99: in start
    self.process(
apache_beam/runners/worker/log_handler_test.py:103: in process
    self.output(windowed_value)
apache_beam/runners/worker/operations.py:567: in apache_beam.runners.worker.operations.Operation.output
    def output(self, windowed_value, output_index=0):
apache_beam/runners/worker/operations.py:569: in apache_beam.runners.worker.operations.Operation.output
    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)
apache_beam/runners/worker/operations.py:260: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    def receive(self, windowed_value):
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError

TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)
self = <apache_beam.runners.worker.log_handler_test.RaiseException object at 0x7aab111531c0>
_ = b'hello, world!'

    def process(self, _):
>     raise RuntimeError(self.msg)
E     RuntimeError: expected exception

apache_beam/runners/worker/log_handler_test.py:56: RuntimeError

During handling of the above exception, another exception occurred:

self = <apache_beam.runners.worker.log_handler_test.FnApiLogRecordHandlerTest testMethod=test_extracts_transform_id_during_exceptions>

    def test_extracts_transform_id_during_exceptions(self):
      """Tests that transform ids are captured during user code exceptions."""
      descriptor = beam_fn_api_pb2.ProcessBundleDescriptor()
    
      # Boiler plate for the DoFn.
      WINDOWING_ID = 'window'
      WINDOW_CODER_ID = 'cw'
      window = descriptor.windowing_strategies[WINDOWING_ID]
      window.window_fn.urn = common_urns.global_windows.urn
      window.window_coder_id = WINDOW_CODER_ID
      window.trigger.default.SetInParent()
      window_coder = descriptor.coders[WINDOW_CODER_ID]
      window_coder.spec.urn = common_urns.StandardCoders.Enum.GLOBAL_WINDOW.urn
    
      # Input collection to the exception raising DoFn.
      INPUT_PCOLLECTION_ID = 'pc-in'
      INPUT_CODER_ID = 'c-in'
      descriptor.pcollections[
          INPUT_PCOLLECTION_ID].unique_name = INPUT_PCOLLECTION_ID
      descriptor.pcollections[INPUT_PCOLLECTION_ID].coder_id = INPUT_CODER_ID
      descriptor.pcollections[
          INPUT_PCOLLECTION_ID].windowing_strategy_id = WINDOWING_ID
      descriptor.coders[
          INPUT_CODER_ID].spec.urn = common_urns.StandardCoders.Enum.BYTES.urn
    
      # Output collection to the exception raising DoFn.
      OUTPUT_PCOLLECTION_ID = 'pc-out'
      OUTPUT_CODER_ID = 'c-out'
      descriptor.pcollections[
          OUTPUT_PCOLLECTION_ID].unique_name = OUTPUT_PCOLLECTION_ID
      descriptor.pcollections[OUTPUT_PCOLLECTION_ID].coder_id = OUTPUT_CODER_ID
      descriptor.pcollections[
          OUTPUT_PCOLLECTION_ID].windowing_strategy_id = WINDOWING_ID
      descriptor.coders[
          OUTPUT_CODER_ID].spec.urn = common_urns.StandardCoders.Enum.BYTES.urn
    
      # Add a simple transform to inject an element into the fake pipeline.
      TEST_OP_TRANSFORM_ID = 'test_op'
      test_transform = descriptor.transforms[TEST_OP_TRANSFORM_ID]
      test_transform.outputs['None'] = INPUT_PCOLLECTION_ID
      test_transform.spec.urn = 'beam:internal:testop:v1'
      test_transform.spec.payload = b'hello, world!'
    
      # Add the DoFn to create an exception.
      TEST_EXCEPTION_TRANSFORM_ID = 'test_transform'
      test_transform = descriptor.transforms[TEST_EXCEPTION_TRANSFORM_ID]
      test_transform.inputs['0'] = INPUT_PCOLLECTION_ID
      test_transform.outputs['None'] = OUTPUT_PCOLLECTION_ID
      test_transform.spec.urn = 'beam:internal:testexn:v1'
      test_transform.spec.payload = b'expected exception'
    
      # Create and process a fake bundle. The instruction id doesn't matter
      # here.
      processor = BundleProcessor(set(), descriptor, None, None)
    
      with self.assertRaisesRegex(RuntimeError, 'expected exception'):
>       processor.process_bundle('instruction_id')

apache_beam/runners/worker/log_handler_test.py:292: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
target/.tox-py39-cloud/py39-cloud/lib/python3.9/site-packages/apache_beam/runners/worker/bundle_processor.py:1227: in process_bundle
    op.start()
apache_beam/runners/worker/log_handler_test.py:99: in start
    self.process(
apache_beam/runners/worker/log_handler_test.py:103: in process
    self.output(windowed_value)
apache_beam/runners/worker/operations.py:567: in apache_beam.runners.worker.operations.Operation.output
    def output(self, windowed_value, output_index=0):
apache_beam/runners/worker/operations.py:569: in apache_beam.runners.worker.operations.Operation.output
    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)
apache_beam/runners/worker/operations.py:260: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    def receive(self, windowed_value):
apache_beam/runners/worker/operations.py:263: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:951: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1503: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

>   self._maybe_sample_exception(exc_info, windowed_value)
E   TypeError: Argument 'exn' has incorrect type (expected BaseException, got tuple)

apache_beam/runners/common.py:1611: TypeError