AssertionError: Lists differ: ["amy[54 chars]]", "carl; ['[email protected]', '[email protected][85 chars] []"] != ["amy[54 chars]]", "amy; ['[email protected]']; ['111-222-3333'[280 chars] []"]

First differing element 1:
"carl; ['[email protected]', '[email protected]']; ['444-555-6666']"
"amy; ['[email protected]']; ['111-222-3333', '333-444-5555']"

Second list contains 4 additional elements.
First extra element 4:
"james; []; ['222-333-4444']"

  ["amy; ['[email protected]']; ['111-222-3333', '333-444-5555']",
+  "amy; ['[email protected]']; ['111-222-3333', '333-444-5555']",
+  "carl; ['[email protected]', '[email protected]']; ['444-555-6666']",
   "carl; ['[email protected]', '[email protected]']; ['444-555-6666']",
   "james; []; ['222-333-4444']",
+  "james; []; ['222-333-4444']",
+  "julia; ['[email protected]']; []",
   "julia; ['[email protected]']; []"]
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_co_group_by_key_tuple>

    def test_model_co_group_by_key_tuple(self):
      with TestPipeline() as p:
        # [START model_group_by_key_cogroupbykey_tuple_inputs]
        emails_list = [
            ('amy', '[email protected]'),
            ('carl', '[email protected]'),
            ('julia', '[email protected]'),
            ('carl', '[email protected]'),
        ]
        phones_list = [
            ('amy', '111-222-3333'),
            ('james', '222-333-4444'),
            ('amy', '333-444-5555'),
            ('carl', '444-555-6666'),
        ]
    
        emails = p | 'CreateEmails' >> beam.Create(emails_list)
        phones = p | 'CreatePhones' >> beam.Create(phones_list)
        # [END model_group_by_key_cogroupbykey_tuple_inputs]
    
        result_path = self.create_temp_file()
        snippets.model_co_group_by_key_tuple(emails, phones, result_path)
    
      # [START model_group_by_key_cogroupbykey_tuple_outputs]
      results = [
          (
              'amy',
              {
                  'emails': ['[email protected]'],
                  'phones': ['111-222-3333', '333-444-5555']
              }),
          (
              'carl',
              {
                  'emails': ['[email protected]', '[email protected]'],
                  'phones': ['444-555-6666']
              }),
          ('james', {
              'emails': [], 'phones': ['222-333-4444']
          }),
          ('julia', {
              'emails': ['[email protected]'], 'phones': []
          }),
      ]
      # [END model_group_by_key_cogroupbykey_tuple_outputs]
      # [START model_group_by_key_cogroupbykey_tuple_formatted_outputs]
      formatted_results = [
          "amy; ['[email protected]']; ['111-222-3333', '333-444-5555']",
          "carl; ['[email protected]', '[email protected]']; ['444-555-6666']",
          "james; []; ['222-333-4444']",
          "julia; ['[email protected]']; []",
      ]
      # [END model_group_by_key_cogroupbykey_tuple_formatted_outputs]
      expected_results = [
          '%s; %s; %s' % (name, info['emails'], info['phones']) for name,
          info in results
      ]
      self.assertEqual(expected_results, formatted_results)
>     self.assertEqual(formatted_results, self.get_output(result_path))
E     AssertionError: Lists differ: ["amy[54 chars]]", "carl; ['[email protected]', '[email protected][85 chars] []"] != ["amy[54 chars]]", "amy; ['[email protected]']; ['111-222-3333'[280 chars] []"]
E     
E     First differing element 1:
E     "carl; ['[email protected]', '[email protected]']; ['444-555-6666']"
E     "amy; ['[email protected]']; ['111-222-3333', '333-444-5555']"
E     
E     Second list contains 4 additional elements.
E     First extra element 4:
E     "james; []; ['222-333-4444']"
E     
E       ["amy; ['[email protected]']; ['111-222-3333', '333-444-5555']",
E     +  "amy; ['[email protected]']; ['111-222-3333', '333-444-5555']",
E     +  "carl; ['[email protected]', '[email protected]']; ['444-555-6666']",
E        "carl; ['[email protected]', '[email protected]']; ['444-555-6666']",
E        "james; []; ['222-333-4444']",
E     +  "james; []; ['222-333-4444']",
E     +  "julia; ['[email protected]']; []",
E        "julia; ['[email protected]']; []"]

apache_beam/examples/snippets/snippets_test.py:1005: AssertionError

AssertionError: Lists differ: ['aa: 1', 'bb: 2', 'cc: 3'] != ['aa: 1', 'aa: 1', 'bb: 2', 'bb: 2', 'cc: 3', 'cc: 3']

First differing element 1:
'bb: 2'
'aa: 1'

Second list contains 3 additional elements.
First extra element 3:
'bb: 2'

- ['aa: 1', 'bb: 2', 'cc: 3']
+ ['aa: 1', 'aa: 1', 'bb: 2', 'bb: 2', 'cc: 3', 'cc: 3']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_composite_transform_example>

    def test_model_composite_transform_example(self):
      contents = ['aa bb cc', 'bb cc', 'cc']
      result_path = self.create_temp_file()
      snippets.model_composite_transform_example(contents, result_path)
>     self.assertEqual(['aa: 1', 'bb: 2', 'cc: 3'], self.get_output(result_path))
E     AssertionError: Lists differ: ['aa: 1', 'bb: 2', 'cc: 3'] != ['aa: 1', 'aa: 1', 'bb: 2', 'bb: 2', 'cc: 3', 'cc: 3']
E     
E     First differing element 1:
E     'bb: 2'
E     'aa: 1'
E     
E     Second list contains 3 additional elements.
E     First extra element 3:
E     'bb: 2'
E     
E     - ['aa: 1', 'bb: 2', 'cc: 3']
E     + ['aa: 1', 'aa: 1', 'bb: 2', 'bb: 2', 'cc: 3', 'cc: 3']

apache_beam/examples/snippets/snippets_test.py:912: AssertionError

AssertionError: Lists differ: ['11', '11', '12', '12', '13', '13'] != ['11', '12', '13']

First differing element 1:
'11'
'12'

First list contains 3 additional elements.
First extra element 3:
'12'

- ['11', '11', '12', '12', '13', '13']
+ ['11', '12', '13']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_examples_ptransforms_templated>

    def test_examples_ptransforms_templated(self):
      pipelines = [snippets.examples_ptransforms_templated]
    
      for pipeline in pipelines:
        temp_path = self.create_temp_file('1\n 2\n 3')
        result_path = self.create_temp_file()
        pipeline({'read': temp_path, 'write': result_path})
>       self.assertEqual(self.get_output(result_path), ['11', '12', '13'])
E       AssertionError: Lists differ: ['11', '11', '12', '12', '13', '13'] != ['11', '12', '13']
E       
E       First differing element 1:
E       '11'
E       '12'
E       
E       First list contains 3 additional elements.
E       First extra element 3:
E       '12'
E       
E       - ['11', '11', '12', '12', '13', '13']
E       + ['11', '12', '13']

apache_beam/examples/snippets/snippets_test.py:828: AssertionError

AssertionError: assert not True
 +  where True = <function exists at 0x7ffa9c482320>('/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/tmp/tmpgrrfa146/final_table_no_ptransform0')
 +    where <function exists at 0x7ffa9c482320> = <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'>.exists
 +      where <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'> = os.path [while running 'WriteToSimpleKV/WriteImpl/FinalizeWrite']
self = <apache_beam.examples.snippets.snippets_test.SimpleKV object at 0x7ffa5433a890>
access_token = 'dummy_token'
old_name = 'tablef5edddd4-76d6-490c-93a9-2c7b2a8e61f7'
new_name = 'final_table_no_ptransform0'

    def rename_table(self, access_token, old_name, new_name):
      assert access_token == self._dummy_token
      old_file_name = self._tmp_dir + os.sep + old_name
      new_file_name = self._tmp_dir + os.sep + new_name
      assert os.path.isfile(old_file_name)
>     assert not os.path.exists(new_file_name)
E     AssertionError: assert not True
E      +  where True = <function exists at 0x7ffa9c482320>('/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/tmp/tmpgrrfa146/final_table_no_ptransform0')
E      +    where <function exists at 0x7ffa9c482320> = <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'>.exists
E      +      where <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'> = os.path

apache_beam/examples/snippets/snippets_test.py:673: AssertionError

During handling of the above exception, another exception occurred:

self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_custom_sink>

    def test_model_custom_sink(self):
      tempdir_name = tempfile.mkdtemp()
    
      class SimpleKV(object):
        def __init__(self, tmp_dir):
          self._dummy_token = 'dummy_token'
          self._tmp_dir = tmp_dir
    
        def connect(self, url):
          return self._dummy_token
    
        def open_table(self, access_token, table_name):
          assert access_token == self._dummy_token
          file_name = self._tmp_dir + os.sep + table_name
          assert not os.path.exists(file_name)
          open(file_name, 'wb').close()
          return table_name
    
        def write_to_table(self, access_token, table_name, key, value):
          assert access_token == self._dummy_token
          file_name = self._tmp_dir + os.sep + table_name
          assert os.path.exists(file_name)
          with open(file_name, 'ab') as f:
            content = (key + ':' + value + os.linesep).encode('utf-8')
            f.write(content)
    
        def rename_table(self, access_token, old_name, new_name):
          assert access_token == self._dummy_token
          old_file_name = self._tmp_dir + os.sep + old_name
          new_file_name = self._tmp_dir + os.sep + new_name
          assert os.path.isfile(old_file_name)
          assert not os.path.exists(new_file_name)
    
          os.rename(old_file_name, new_file_name)
    
>     snippets.model_custom_sink(
          SimpleKV(tempdir_name),
          [('key' + str(i), 'value' + str(i)) for i in range(100)],
          'final_table_no_ptransform',
          'final_table_with_ptransform')

apache_beam/examples/snippets/snippets_test.py:677: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/examples/snippets/snippets.py:794: in model_custom_sink
    with beam.Pipeline(options=PipelineOptions()) as pipeline:
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/pipeline.py:644: in __exit__
    self.result = self.run()
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/pipeline.py:618: in run
    return self.runner.run_pipeline(self, self._options)
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/direct/direct_runner.py:190: in run_pipeline
    return runner.run_pipeline(pipeline, options)
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:196: in run_pipeline
    self._latest_run_result = self.run_via_runner_api(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:223: in run_via_runner_api
    return self.run_stages(stage_context, stages)
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:470: in run_stages
    bundle_results = self._execute_bundle(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:795: in _execute_bundle
    self._run_bundle(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:1034: in _run_bundle
    result, splits = bundle_manager.process_bundle(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py:1360: in process_bundle
    result_future = self._worker_handler.control_conn.push(process_bundle_req)
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/portability/fn_api_runner/worker_handlers.py:386: in push
    response = self.worker.do_instruction(request)
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py:658: in do_instruction
    return getattr(self, request_type)(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py:696: in process_bundle
    bundle_processor.process_bundle(instruction_id))
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/bundle_processor.py:1274: in process_bundle
    input_op_by_transform_id[element.transform_id].process_encoded(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/bundle_processor.py:237: in process_encoded
    self.output(decoded_value)
apache_beam/runners/worker/operations.py:566: in apache_beam.runners.worker.operations.Operation.output
    def output(self, windowed_value, output_index=0):
apache_beam/runners/worker/operations.py:568: in apache_beam.runners.worker.operations.Operation.output
    _cast_to_receiver(self.receivers[output_index]).receive(windowed_value)
apache_beam/runners/worker/operations.py:259: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    def receive(self, windowed_value):
apache_beam/runners/worker/operations.py:262: in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
    self.consumer.process(windowed_value)
apache_beam/runners/worker/operations.py:949: in apache_beam.runners.worker.operations.DoOperation.process
    with self.scoped_process_state:
apache_beam/runners/worker/operations.py:950: in apache_beam.runners.worker.operations.DoOperation.process
    delayed_applications = self.dofn_runner.process(o)
apache_beam/runners/common.py:1497: in apache_beam.runners.common.DoFnRunner.process
    self._reraise_augmented(exn, windowed_value)
apache_beam/runners/common.py:1606: in apache_beam.runners.common.DoFnRunner._reraise_augmented
    raise new_exn
apache_beam/runners/common.py:1495: in apache_beam.runners.common.DoFnRunner.process
    return self.do_fn_invoker.invoke_process(windowed_value)
apache_beam/runners/common.py:911: in apache_beam.runners.common.PerWindowInvoker.invoke_process
    self._invoke_process_per_window(
apache_beam/runners/common.py:1055: in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
    self.process_method(*args_for_process, **kwargs_for_process),
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/iobase.py:1237: in _finalize_write
    outputs = sink.finalize_write(
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/examples/snippets/snippets.py:703: in finalize_write
    self._simplekv.rename_table(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.examples.snippets.snippets_test.SimpleKV object at 0x7ffa5433a890>
access_token = 'dummy_token'
old_name = 'tablef5edddd4-76d6-490c-93a9-2c7b2a8e61f7'
new_name = 'final_table_no_ptransform0'

    def rename_table(self, access_token, old_name, new_name):
      assert access_token == self._dummy_token
      old_file_name = self._tmp_dir + os.sep + old_name
      new_file_name = self._tmp_dir + os.sep + new_name
      assert os.path.isfile(old_file_name)
>     assert not os.path.exists(new_file_name)
E     AssertionError: assert not True
E      +  where True = <function exists at 0x7ffa9c482320>('/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/tmp/tmpgrrfa146/final_table_no_ptransform0')
E      +    where <function exists at 0x7ffa9c482320> = <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'>.exists
E      +      where <module 'posixpath' from '/opt/hostedtoolcache/Python/3.10.17/x64/lib/python3.10/posixpath.py'> = os.path [while running 'WriteToSimpleKV/WriteImpl/FinalizeWrite']

apache_beam/examples/snippets/snippets_test.py:673: AssertionError

AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

First differing element 1:
'abc: 2'
'def: 1'

First list contains 4 additional elements.
First extra element 4:
'ghi: 1'

- ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
+ ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
a = (<apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_examples_wordcount_0>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)

target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/examples/snippets/snippets_test.py:818: in test_examples_wordcount
    self.assertEqual(
E   AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
E   
E   First differing element 1:
E   'abc: 2'
E   'def: 1'
E   
E   First list contains 4 additional elements.
E   First extra element 4:
E   'ghi: 1'
E   
E   - ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
E   + ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

First differing element 1:
'abc: 2'
'def: 1'

First list contains 4 additional elements.
First extra element 4:
'ghi: 1'

- ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
+ ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
a = (<apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_examples_wordcount_1>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)

target/.tox-py310/py310/lib/python3.10/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/examples/snippets/snippets_test.py:818: in test_examples_wordcount
    self.assertEqual(
E   AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
E   
E   First differing element 1:
E   'abc: 2'
E   'def: 1'
E   
E   First list contains 4 additional elements.
E   First extra element 4:
E   'ghi: 1'
E   
E   - ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
E   + ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

AssertionError: Lists differ: ['a; [19 chars]2', 'b; [email protected]; x8452'] != ['a; [19 chars]2', 'a; [email protected]; x4312', 'b; [email protected][33 chars]452']

First differing element 1:
'b; [email protected]; x8452'
'a; [email protected]; x4312'

Second list contains 2 additional elements.
First extra element 2:
'b; [email protected]; x8452'

- ['a; [email protected]; x4312', 'b; [email protected]; x8452']
+ ['a; [email protected]; x4312',
+  'a; [email protected]; x4312',
+  'b; [email protected]; x8452',
+  'b; [email protected]; x8452']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_join_using_side_inputs>

    def test_model_join_using_side_inputs(self):
      name_list = ['a', 'b']
      email_list = [['a', '[email protected]'], ['b', '[email protected]']]
      phone_list = [['a', 'x4312'], ['b', 'x8452']]
      result_path = self.create_temp_file()
      snippets.model_join_using_side_inputs(
          name_list, email_list, phone_list, result_path)
      expect = ['a; [email protected]; x4312', 'b; [email protected]; x8452']
>     self.assertEqual(expect, self.get_output(result_path))
E     AssertionError: Lists differ: ['a; [19 chars]2', 'b; [email protected]; x8452'] != ['a; [19 chars]2', 'a; [email protected]; x4312', 'b; [email protected][33 chars]452']
E     
E     First differing element 1:
E     'b; [email protected]; x8452'
E     'a; [email protected]; x4312'
E     
E     Second list contains 2 additional elements.
E     First extra element 2:
E     'b; [email protected]; x8452'
E     
E     - ['a; [email protected]; x4312', 'b; [email protected]; x8452']
E     + ['a; [email protected]; x4312',
E     +  'a; [email protected]; x4312',
E     +  'b; [email protected]; x8452',
E     +  'b; [email protected]; x8452']

apache_beam/examples/snippets/snippets_test.py:1075: AssertionError

AssertionError: Lists differ: [1111] != [1111, 1111]

Second list contains 1 additional elements.
First extra element 1:
1111

- [1111]
+ [1111, 1111]
self = <apache_beam.examples.snippets.snippets_test.CombineTest testMethod=test_bounded_sum>

    def test_bounded_sum(self):
      # [START combine_bounded_sum]
      pc = [1, 10, 100, 1000]
    
      def bounded_sum(values, bound=500):
        return min(sum(values), bound)
    
      small_sum = pc | beam.CombineGlobally(bounded_sum)  # [500]
      large_sum = pc | beam.CombineGlobally(bounded_sum, bound=5000)  # [1111]
      # [END combine_bounded_sum]
      self.assertEqual([500], small_sum)
>     self.assertEqual([1111], large_sum)
E     AssertionError: Lists differ: [1111] != [1111, 1111]
E     
E     Second list contains 1 additional elements.
E     First extra element 1:
E     1111
E     
E     - [1111]
E     + [1111, 1111]

apache_beam/examples/snippets/snippets_test.py:1245: AssertionError

AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

First differing element 1:
'abc: 2'
'def: 1'

First list contains 4 additional elements.
First extra element 4:
'ghi: 1'

- ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
+ ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
a = (<apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_examples_wordcount_2>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)

target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/examples/snippets/snippets_test.py:818: in test_examples_wordcount
    self.assertEqual(
E   AssertionError: Lists differ: ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1'] != ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']
E   
E   First differing element 1:
E   'abc: 2'
E   'def: 1'
E   
E   First list contains 4 additional elements.
E   First extra element 4:
E   'ghi: 1'
E   
E   - ['abc: 2', 'abc: 2', 'def: 1', 'def: 1', 'ghi: 1', 'ghi: 1', 'jkl: 1', 'jkl: 1']
E   + ['abc: 2', 'def: 1', 'ghi: 1', 'jkl: 1']

AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']

First differing element 1:
'b'
'a'

Second list contains 6 additional elements.
First extra element 6:
'd'

- ['a', 'b', 'c', 'd', 'e', 'f']
+ ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_multiple_pcollections_flatten>

    def test_model_multiple_pcollections_flatten(self):
      contents = ['a', 'b', 'c', 'd', 'e', 'f']
      result_path = self.create_temp_file()
      snippets.model_multiple_pcollections_flatten(contents, result_path)
>     self.assertEqual(contents, self.get_output(result_path))
E     AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']
E     
E     First differing element 1:
E     'b'
E     'a'
E     
E     Second list contains 6 additional elements.
E     First extra element 6:
E     'd'
E     
E     - ['a', 'b', 'c', 'd', 'e', 'f']
E     + ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']

apache_beam/examples/snippets/snippets_test.py:918: AssertionError

AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']

First differing element 1:
'b'
'a'

Second list contains 6 additional elements.
First extra element 6:
'd'

- ['a', 'b', 'c', 'd', 'e', 'f']
+ ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_multiple_pcollections_flatten_with>

    def test_model_multiple_pcollections_flatten_with(self):
      contents = ['a', 'b', 'c', 'd', 'e', 'f']
      result_path = self.create_temp_file()
      snippets.model_multiple_pcollections_flatten_with(contents, result_path)
>     self.assertEqual(contents, self.get_output(result_path))
E     AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']
E     
E     First differing element 1:
E     'b'
E     'a'
E     
E     Second list contains 6 additional elements.
E     First extra element 6:
E     'd'
E     
E     - ['a', 'b', 'c', 'd', 'e', 'f']
E     + ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e', 'f', 'f']

apache_beam/examples/snippets/snippets_test.py:924: AssertionError

AssertionError: Lists differ: ['Flourish: 3', 'Flourish: 3', 'stomach: 1', 'stomach: 1'] != ['Flourish: 3', 'stomach: 1']

First differing element 1:
'Flourish: 3'
'stomach: 1'

First list contains 2 additional elements.
First extra element 2:
'stomach: 1'

- ['Flourish: 3', 'Flourish: 3', 'stomach: 1', 'stomach: 1']
+ ['Flourish: 3', 'stomach: 1']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_examples_wordcount_debugging>

    def test_examples_wordcount_debugging(self):
      temp_path = self.create_temp_file(
          'Flourish Flourish Flourish stomach abc def')
      result_path = self.create_temp_file()
      snippets_examples_wordcount_debugging.examples_wordcount_debugging({
          'read': temp_path, 'write': result_path
      })
>     self.assertEqual(
          self.get_output(result_path), ['Flourish: 3', 'stomach: 1'])
E     AssertionError: Lists differ: ['Flourish: 3', 'Flourish: 3', 'stomach: 1', 'stomach: 1'] != ['Flourish: 3', 'stomach: 1']
E     
E     First differing element 1:
E     'Flourish: 3'
E     'stomach: 1'
E     
E     First list contains 2 additional elements.
E     First extra element 2:
E     'stomach: 1'
E     
E     - ['Flourish: 3', 'Flourish: 3', 'stomach: 1', 'stomach: 1']
E     + ['Flourish: 3', 'stomach: 1']

apache_beam/examples/snippets/snippets_test.py:837: AssertionError

AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f', 'x', 'y', 'z'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e[37 chars] 'z']

First differing element 1:
'b'
'a'

Second list contains 9 additional elements.
First extra element 9:
'e'

- ['a', 'b', 'c', 'd', 'e', 'f', 'x', 'y', 'z']
+ ['a',
+  'a',
+  'b',
+  'b',
+  'c',
+  'c',
+  'd',
+  'd',
+  'e',
+  'e',
+  'f',
+  'f',
+  'x',
+  'x',
+  'y',
+  'y',
+  'z',
+  'z']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_multiple_pcollections_flatten_with_transform>

    def test_model_multiple_pcollections_flatten_with_transform(self):
      contents = ['a', 'b', 'c', 'd', 'e', 'f']
      result_path = self.create_temp_file()
      snippets.model_multiple_pcollections_flatten_with_transform(
          contents, result_path)
>     self.assertEqual(contents + ['x', 'y', 'z'], self.get_output(result_path))
E     AssertionError: Lists differ: ['a', 'b', 'c', 'd', 'e', 'f', 'x', 'y', 'z'] != ['a', 'a', 'b', 'b', 'c', 'c', 'd', 'd', 'e', 'e[37 chars] 'z']
E     
E     First differing element 1:
E     'b'
E     'a'
E     
E     Second list contains 9 additional elements.
E     First extra element 9:
E     'e'
E     
E     - ['a', 'b', 'c', 'd', 'e', 'f', 'x', 'y', 'z']
E     + ['a',
E     +  'a',
E     +  'b',
E     +  'b',
E     +  'c',
E     +  'c',
E     +  'd',
E     +  'd',
E     +  'e',
E     +  'e',
E     +  'f',
E     +  'f',
E     +  'x',
E     +  'x',
E     +  'y',
E     +  'y',
E     +  'z',
E     +  'z']

apache_beam/examples/snippets/snippets_test.py:931: AssertionError

AssertionError: Lists differ: ['a', 'are', 'found', 'found', 'found', 'from', '[111 chars]ere'] != ['a', 'a', 'are', 'are', 'found', 'found', 'found[276 chars]ere']

First differing element 1:
'are'
'a'

Second list contains 21 additional elements.
First extra element 21:
'love'

  ['a',
+  'a',
+  'are',
   'are',
   'found',
   'found',
   'found',
+  'found',
+  'found',
+  'found',
+  'from',
   'from',
   'hopeless',
+  'hopeless',
+  'in',
   'in',
   'love',
   'love',
   'love',
+  'love',
+  'love',
+  'love',
+  'place',
   'place',
   'right',
   'right',
+  'right',
+  'right',
   'start',
+  'start',
+  'the',
   'the',
   'we',
   'we',
   'we',
   'we',
+  'we',
+  'we',
+  'we',
+  'we',
+  'where',
   'where']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_pipeline_logging>

    def test_pipeline_logging(self):
      result_path = self.create_temp_file()
      lines = [
          'we found love right where we are',
          'we found love right from the start',
          'we found love in a hopeless place'
      ]
      snippets.pipeline_logging(lines, result_path)
>     self.assertEqual(
          sorted(' '.join(lines).split(' ')), self.get_output(result_path))
E     AssertionError: Lists differ: ['a', 'are', 'found', 'found', 'found', 'from', '[111 chars]ere'] != ['a', 'a', 'are', 'are', 'found', 'found', 'found[276 chars]ere']
E     
E     First differing element 1:
E     'are'
E     'a'
E     
E     Second list contains 21 additional elements.
E     First extra element 21:
E     'love'
E     
E       ['a',
E     +  'a',
E     +  'are',
E        'are',
E        'found',
E        'found',
E        'found',
E     +  'found',
E     +  'found',
E     +  'found',
E     +  'from',
E        'from',
E        'hopeless',
E     +  'hopeless',
E     +  'in',
E        'in',
E        'love',
E        'love',
E        'love',
E     +  'love',
E     +  'love',
E     +  'love',
E     +  'place',
E        'place',
E        'right',
E        'right',
E     +  'right',
E     +  'right',
E        'start',
E     +  'start',
E     +  'the',
E        'the',
E        'we',
E        'we',
E        'we',
E        'we',
E     +  'we',
E     +  'we',
E     +  'we',
E     +  'we',
E     +  'where',
E        'where']

apache_beam/examples/snippets/snippets_test.py:799: AssertionError

AssertionError: Lists differ: ['Or [39 chars] ', 'Or to take arms against a sea of troubles[283 chars]er "] != ['Or [39 chars] ', 'The slings and arrows of outrageous fortu[94 chars]er "]

First differing element 1:
'Or to take arms against a sea of troubles, '
'The slings and arrows of outrageous fortune, '

First list contains 4 additional elements.
First extra element 4:
'To be, or not to be: that is the question: '

  ['Or to take arms against a sea of troubles, ',
-  'Or to take arms against a sea of troubles, ',
-  'The slings and arrows of outrageous fortune, ',
   'The slings and arrows of outrageous fortune, ',
   'To be, or not to be: that is the question: ',
-  'To be, or not to be: that is the question: ',
-  "Whether 'tis nobler in the mind to suffer ",
   "Whether 'tis nobler in the mind to suffer "]
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_model_pcollection>

    def test_model_pcollection(self):
      temp_path = self.create_temp_file()
      snippets.model_pcollection(temp_path)
>     self.assertEqual(
          self.get_output(temp_path),
          [
              'Or to take arms against a sea of troubles, ',
              'The slings and arrows of outrageous fortune, ',
              'To be, or not to be: that is the question: ',
              'Whether \'tis nobler in the mind to suffer ',
          ])
E     AssertionError: Lists differ: ['Or [39 chars] ', 'Or to take arms against a sea of troubles[283 chars]er "] != ['Or [39 chars] ', 'The slings and arrows of outrageous fortu[94 chars]er "]
E     
E     First differing element 1:
E     'Or to take arms against a sea of troubles, '
E     'The slings and arrows of outrageous fortune, '
E     
E     First list contains 4 additional elements.
E     First extra element 4:
E     'To be, or not to be: that is the question: '
E     
E       ['Or to take arms against a sea of troubles, ',
E     -  'Or to take arms against a sea of troubles, ',
E     -  'The slings and arrows of outrageous fortune, ',
E        'The slings and arrows of outrageous fortune, ',
E        'To be, or not to be: that is the question: ',
E     -  'To be, or not to be: that is the question: ',
E     -  "Whether 'tis nobler in the mind to suffer ",
E        "Whether 'tis nobler in the mind to suffer "]

apache_beam/examples/snippets/snippets_test.py:622: AssertionError

AssertionError: Lists differ: ['aa', 'bb', 'cc'] != ['aa', 'aa', 'aa', 'bb', 'bb', 'bb', 'cc', 'cc', 'cc']

First differing element 1:
'bb'
'aa'

Second list contains 6 additional elements.
First extra element 3:
'bb'

- ['aa', 'bb', 'cc']
+ ['aa', 'aa', 'aa', 'bb', 'bb', 'bb', 'cc', 'cc', 'cc']
self = <apache_beam.examples.snippets.snippets_test.SnippetsTest testMethod=test_pipeline_options_remote>

    def test_pipeline_options_remote(self):
>     self._run_test_pipeline_for_options(snippets.pipeline_options_remote)

apache_beam/examples/snippets/snippets_test.py:786: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/examples/snippets/snippets_test.py:780: in _run_test_pipeline_for_options
    self.assertEqual(['aa', 'bb', 'cc'], self.get_output(result_path))
E   AssertionError: Lists differ: ['aa', 'bb', 'cc'] != ['aa', 'aa', 'aa', 'bb', 'bb', 'bb', 'cc', 'cc', 'cc']
E   
E   First differing element 1:
E   'bb'
E   'aa'
E   
E   Second list contains 6 additional elements.
E   First extra element 3:
E   'bb'
E   
E   - ['aa', 'bb', 'cc']
E   + ['aa', 'aa', 'aa', 'bb', 'bb', 'bb', 'cc', 'cc', 'cc']

AssertionError: Lists differ: [4.25] != [4.25, 4.25]

Second list contains 1 additional elements.
First extra element 1:
4.25

- [4.25]
+ [4.25, 4.25]
self = <apache_beam.examples.snippets.snippets_test.CombineTest testMethod=test_custom_average>

    def test_custom_average(self):
      pc = [2, 3, 5, 7]
    
      # [START combine_custom_average_define]
      class AverageFn(beam.CombineFn):
        def create_accumulator(self):
          return (0.0, 0)
    
        def add_input(self, sum_count, input):
          (sum, count) = sum_count
          return sum + input, count + 1
    
        def merge_accumulators(self, accumulators):
          sums, counts = zip(*accumulators)
          return sum(sums), sum(counts)
    
        def extract_output(self, sum_count):
          (sum, count) = sum_count
          return sum / count if count else float('NaN')
    
        def compact(self, accumulator):
          # No-op
          return accumulator
    
      # [END combine_custom_average_define]
      # [START combine_custom_average_execute]
      average = pc | beam.CombineGlobally(AverageFn())
      # [END combine_custom_average_execute]
>     self.assertEqual([4.25], average)
E     AssertionError: Lists differ: [4.25] != [4.25, 4.25]
E     
E     Second list contains 1 additional elements.
E     First extra element 1:
E     4.25
E     
E     - [4.25]
E     + [4.25, 4.25]

apache_beam/examples/snippets/snippets_test.py:1285: AssertionError

AssertionError: Items in the first set but not the second:
" gender='1'"
' sale_price=15.0'
" state='1'"
' product_id=14235'
" country='1')"
"Row(user_id='2963'"
Items in the second set but not the first:
' product_id=11203'
" state='0'"
" gender='0'"
" country='0')"
' sale_price=12.0'
"Row(user_id='21422'"
self = <apache_beam.examples.snippets.transforms.elementwise.enrichment_test.EnrichmentTest testMethod=test_enrichment_with_vertex_ai>
mock_stdout = <_io.StringIO object at 0x7fe220322710>

    def test_enrichment_with_vertex_ai(self, mock_stdout):
      enrichment_with_vertex_ai()
      output = mock_stdout.getvalue().splitlines()
      expected = validate_enrichment_with_vertex_ai()
    
      for i in range(len(expected)):
>       self.assertEqual(set(output[i].split(',')), set(expected[i].split(',')))
E       AssertionError: Items in the first set but not the second:
E       " gender='1'"
E       ' sale_price=15.0'
E       " state='1'"
E       ' product_id=14235'
E       " country='1')"
E       "Row(user_id='2963'"
E       Items in the second set but not the first:
E       ' product_id=11203'
E       " state='0'"
E       " gender='0'"
E       " country='0')"
E       ' sale_price=12.0'
E       "Row(user_id='21422'"

apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py:77: AssertionError

AssertionError: Lists differ: ["Row[141 chars]e_id=1, customer_id=1, product_id=1, quantity=[489 chars]'})"] != ["Row[141 chars]e_id=3, customer_id=3, product_id=2, quantity=[215 chars]'})"]

First differing element 1:
"Row(sale_id=1, customer_id=1, product_id=1, quantity=[76 chars]2'})"
"Row(sale_id=3, customer_id=3, product_id=2, quantity=[76 chars]4'})"

First list contains 2 additional elements.
First extra element 3:
"Row(sale_id=3, customer_id=3, product_id=2, quantity=3, product={'product_id': '2', 'product_name': 'pixel 6', 'product_stock': '4'})"

Diff is 761 characters long. Set self.maxDiff to None to see it.
self = <apache_beam.examples.snippets.transforms.elementwise.enrichment_test.EnrichmentTest testMethod=test_enrichment_with_bigtable>
mock_stdout = <_io.StringIO object at 0x7b13242eb370>

    def test_enrichment_with_bigtable(self, mock_stdout):
      enrichment_with_bigtable()
      output = mock_stdout.getvalue().splitlines()
      expected = validate_enrichment_with_bigtable()
>     self.assertEqual(output, expected)
E     AssertionError: Lists differ: ["Row[141 chars]e_id=1, customer_id=1, product_id=1, quantity=[489 chars]'})"] != ["Row[141 chars]e_id=3, customer_id=3, product_id=2, quantity=[215 chars]'})"]
E     
E     First differing element 1:
E     "Row(sale_id=1, customer_id=1, product_id=1, quantity=[76 chars]2'})"
E     "Row(sale_id=3, customer_id=3, product_id=2, quantity=[76 chars]4'})"
E     
E     First list contains 2 additional elements.
E     First extra element 3:
E     "Row(sale_id=3, customer_id=3, product_id=2, quantity=3, product={'product_id': '2', 'product_name': 'pixel 6', 'product_stock': '4'})"
E     
E     Diff is 761 characters long. Set self.maxDiff to None to see it.

apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py:69: AssertionError

AssertionError: Lists differ: ["Row[93 chars]vie_01', title='The Shawshank Redemption', gen[285 chars]n')"] != ["Row[93 chars]vie_02', title='The Shining', genres='Horror')[68 chars]n')"]

First differing element 1:
"Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')"
"Row(entity_id='movie_02', title='The Shining', genres='Horror')"

First list contains 3 additional elements.
First extra element 3:
"Row(entity_id='movie_02', title='The Shining', genres='Horror')"

  ["Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')",
-  "Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')",
-  "Row(entity_id='movie_04', title='The Dark Knight', genres='Action')",
-  "Row(entity_id='movie_02', title='The Shining', genres='Horror')",
   "Row(entity_id='movie_02', title='The Shining', genres='Horror')",
   "Row(entity_id='movie_04', title='The Dark Knight', genres='Action')"]
self = <apache_beam.examples.snippets.transforms.elementwise.enrichment_test.EnrichmentTest testMethod=test_enrichment_with_vertex_ai_legacy>
mock_stdout = <_io.StringIO object at 0x7fe0f3a33b50>

    def test_enrichment_with_vertex_ai_legacy(self, mock_stdout):
      enrichment_with_vertex_ai_legacy()
      output = mock_stdout.getvalue().splitlines()
      expected = validate_enrichment_with_vertex_ai_legacy()
      self.maxDiff = None
>     self.assertEqual(output, expected)
E     AssertionError: Lists differ: ["Row[93 chars]vie_01', title='The Shawshank Redemption', gen[285 chars]n')"] != ["Row[93 chars]vie_02', title='The Shining', genres='Horror')[68 chars]n')"]
E     
E     First differing element 1:
E     "Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')"
E     "Row(entity_id='movie_02', title='The Shining', genres='Horror')"
E     
E     First list contains 3 additional elements.
E     First extra element 3:
E     "Row(entity_id='movie_02', title='The Shining', genres='Horror')"
E     
E       ["Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')",
E     -  "Row(entity_id='movie_01', title='The Shawshank Redemption', genres='Drama')",
E     -  "Row(entity_id='movie_04', title='The Dark Knight', genres='Action')",
E     -  "Row(entity_id='movie_02', title='The Shining', genres='Horror')",
E        "Row(entity_id='movie_02', title='The Shining', genres='Horror')",
E        "Row(entity_id='movie_04', title='The Dark Knight', genres='Action')"]

apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py:84: AssertionError

AssertionError: Lists differ: ['__i[113 chars]e', 'setup', 'start_bundle', '* process', '* p[73 chars]own'] != ['__i[113 chars]e', 'teardown']

First differing element 9:
'setup'
'teardown'

First list contains 8 additional elements.
First extra element 10:
'start_bundle'

  ['__init__',
   'setup',
   'start_bundle',
   '* process',
   '* process',
   '* process',
   '* process',
   '* process',
   '* finish_bundle',
-  'setup',
-  'start_bundle',
-  '* process',
-  '* process',
-  '* process',
-  '* process',
-  '* process',
-  '* finish_bundle',
   'teardown']
self = <apache_beam.examples.snippets.transforms.elementwise.pardo_test.ParDoStdoutTest testMethod=test_pardo_dofn_methods>
mock_stdout = <_io.StringIO object at 0x7e089c6a81f0>

    def test_pardo_dofn_methods(self, mock_stdout):
      expected = pardo_dofn_methods.pardo_dofn_methods(check_dofn_methods)
      actual = mock_stdout.getvalue().splitlines()
    
      # For the stdout, check the ordering of the methods, not of the elements.
      actual_stdout = [line.split(':')[0] for line in actual]
      expected_stdout = [line.split(':')[0] for line in expected]
>     self.assertEqual(actual_stdout, expected_stdout)
E     AssertionError: Lists differ: ['__i[113 chars]e', 'setup', 'start_bundle', '* process', '* p[73 chars]own'] != ['__i[113 chars]e', 'teardown']
E     
E     First differing element 9:
E     'setup'
E     'teardown'
E     
E     First list contains 8 additional elements.
E     First extra element 10:
E     'start_bundle'
E     
E       ['__init__',
E        'setup',
E        'start_bundle',
E        '* process',
E        '* process',
E        '* process',
E        '* process',
E        '* process',
E        '* finish_bundle',
E     -  'setup',
E     -  'start_bundle',
E     -  '* process',
E     -  '* process',
E     -  '* process',
E     -  '* process',
E     -  '* process',
E     -  '* finish_bundle',
E        'teardown']

apache_beam/examples/snippets/transforms/elementwise/pardo_test.py:109: AssertionError