Quando executei o tratamento final do pipeline de CHUVAS, o terminal retorna apenas a warning:
WARNING:apache_beam.options.pipeline_options:Discarding invalid overrides: {'argv': None}
Porém, deixei o VS Code rodando e assim que conluído o processo, apareceu todo o feed corretamente. Isso aconteceu apenas com o último comando:
| "Somas das precipitações pela chave" >> beam.CombinePerKey(sum)
Em todas as outras etapas, conforme o cálculo é feito por linha, é póssível ver a atualização. Desse jeito a impressão que passa é que o processo não está rodando.
Alguém saberia dizer por que isso ocorre e como resolver?