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

Reply via email to