HI all
i am starting writing beam test in a new environment and suddenly i am
finding this error
while running a very simple test
def test_word_count(self):
with TestPipeline() as p:
input_data = p | 'Start' >> beam.Create(['hello world', 'hello beam'])
counts = (
input_data
| 'One' >>beam.FlatMap(lambda x: x.split(' '))
| 'Two' >> beam.Map(lambda x: (x, 1))
| 'Three' >> beam.CombinePerKey(sum)
)
debugSink = beam.Map(print)
counts | debugSink
the bot says it's an issue with argparse, and perhaps i have some lib
clash... i fixed it long time ago but now i forgot
Could anyone advise how can i address this problem?
Kind regards
Marco
test_word_count
(shareloader.test.test_stock_pick.TestEdgarUtils.test_word_count) ...
Missing pipeline option (runner). Executing pipeline using the default
runner: DirectRunner.
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
'function' object has no attribute '__self__'
ERROR
======================================================================
ERROR: test_word_count
(shareloader.test.test_stock_pick.TestEdgarUtils.test_word_count)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"/workspaces/GCP_Experiments/dataflow/shareloader/test/test_stock_pick.py",
line 63, in test_word_count
with TestPipeline() as p:
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/pipeline.py",
line 620, in __exit__
self.result = self.run()
^^^^^^^^^^
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/testing/test_pipeline.py",
line 115, in run
result = super().run(
^^^^^^^^^^^^
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/pipeline.py",
line 570, in run
self._options).run(False)
^^^^^^^^^^
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/pipeline.py",
line 594, in run
return self.runner.run_pipeline(self, self._options)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/runners/direct/direct_runner.py",
line 151, in run_pipeline
all_options = options.get_all_options()
^^^^^^^^^^^^^^^^^^^^^^^^^
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/options/pipeline_options.py",
line 351, in get_all_options
cls._add_argparse_args(parser) # pylint: disable=protected-access
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/workspaces/GCP_Experiments/dataflow/samples/email_pipeline.py",
line 46, in _add_argparse_args
parser.add_value_provider_argument('--input_file', type=str,
File
"/home/codespace/.python/current/lib/python3.12/site-packages/apache_beam/options/pipeline_options.py",
line 129, in add_value_provider_argument
self.add_argument(*args, **kwargs)
File "/home/codespace/.python/current/lib/python3.12/argparse.py", line
1472, in add_argument
action = action_class(**kwargs)
^^^^^^^^^^^^^^^^^^^^^^
TypeError: _StoreAction.__init__() got an unexpected keyword argument
'default_value'
