hi when i try to execute my code for a pipeline i am getting this error
$ python main.py --entrada data/muestra.txt --salida NADA --runner
DirectRunner
Traceback (most recent call last):
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/pipeline.py",
line 661, in apply
old_label, transform.label = transform.label, label
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/transforms/ptransform.py",
line 359, in label
return self._user_label or self.default_label()
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/transforms/combiners.py",
line 206, in default_label
return 'Top(%d)' % self._n
TypeError: %d format: a number is required, not NoneType
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "main.py", line 72, in <module>
main()
File "main.py", line 47, in main
run_pipeline(our_args, beam_args)
File "main.py", line 65, in run_pipeline
palabras_top_lista = contadas | "Ranking" >>
beam.combiners.Top.Of(n_palabras, key=lambda kv: kv[1])
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/pvalue.py",
line 137, in __or__
return self.pipeline.apply(ptransform, self)
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/pipeline.py",
line 651, in apply
return self.apply(
File
"/home/luism/pyenviroment/lib/python3.8/site-packages/apache_beam/pipeline.py",
line 664, in apply
transform.label = old_label
UnboundLocalError: local variable 'old_label' referenced before assignment