Traceback (most recent call last):

 "/«PKGBUILDDIR»/nose2/tests/functional/test_loadtests_plugin.py", line 31, in test_package
proc, stderr='test..ltpkg2.tests.Test')

 "/«PKGBUILDDIR»/nose2/tests/_common.py", line 64, in assertTestRunOutputMatches
testf(util.safe_decode(cmd_stderr), stderr)AssertionError: Regex didn't match: 'test..ltpkg2.tests.Test' not found in 'test (ltpkg2.tests.load_tests.<locals>.Test) ... ok\ntest (ltpkg.tests.test_find_these.Test) ... ok\n\n----------------------------------------------------------------------\nRan 2 tests in 0.000s\n\nOK\n'
Traceback (most recent call last):


 "D:/project/Python/TFXTest/examples/iris/iris_pipeline_beam.py", line 181, in <module>

direct_num_workers=0))


 "D:\Program 
s\Anaconda3\lib\site-packages\tfx\orchestration\beam\beam_dag_runner.py", line 154, in run

absl.logging.info('Component %s is scheduled.', component_id)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\pipeline.py", line 426, in __exit__

self.run().wait_until_finish()


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\pipeline.py", line 406, in run

self._options).run(False)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\pipeline.py", line 419, in run

return self.runner.run_pipeline(self, self._options)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\direct\direct_runner.py", line 132, in run_pipeline

return runner.run_pipeline(pipeline, options)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 381, in run_pipeline

default_environment=self._default_environment))


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 388, in run_via_runner_api

return self.run_stages(stage_context, stages)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 470, in run_stages

stage_context.safe_coders)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 753, in _run_stage

result, splits = bundle_manager.process_bundle(data_input, data_output)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 1801, in process_bundle

part, expected_outputs), part_inputs):


 "D:\Program 
s\Anaconda3\lib\concurrent\futures\_base.py", line 586, in result_iterator

yield fs.pop().result()


 "D:\Program 
s\Anaconda3\lib\concurrent\futures\_base.py", line 432, in result

return self.__get_result()


 "D:\Program 
s\Anaconda3\lib\concurrent\futures\_base.py", line 384, in __get_result

raise self._exception


 "D:\Program 
s\Anaconda3\lib\concurrent\futures\thread.py", line 57, in run

result = self.fn(*self.args, **self.kwargs)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 1801, in <lambda>

part, expected_outputs), part_inputs):


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 1737, in process_bundle

result_future = self._worker_handler.control_conn.push(process_bundle_req)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\portability\fn_api_runner.py", line 1150, in push

response = self.worker.do_instruction(request)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\worker\sdk_worker.py", line 360, in do_instruction

request.instruction_id)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\worker\sdk_worker.py", line 386, in process_bundle

bundle_processor.process_bundle(instruction_id))


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\worker\bundle_processor.py", line 663, in process_bundle

data.transform_id].process_encoded(data.data)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\worker\bundle_processor.py", line 143, in process_encoded

self.output(decoded_value)


 "D:\Program 
s\Anaconda3\lib\site-packages\apache_beam\runners\worker\operations.py", line 256, in output

cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)


 "D:\Program 
s\Anaconda3\lib\site-packages\Cython\Shadow.py", line 165, in cast

return type(*args)
TypeError: Receiver() takes no arguments
