 File   "apache_beam/runners/common.py", line 000, in   apache_beam.runners.common.DoFnRunner.process   self.do_fn_invoker.invoke_process(windowed_value) File   "apache_beam/runners/common.py", line 000, in   apache_beam.runners.common.SimpleInvoker.invoke_process   self.output_processor.process_outputs( File   "apache_beam/runners/common.py", line 000, in   apache_beam.runners.common._OutputProcessor.process_outputs   self.main_receivers.receive(windowed_value) File   "apache_beam/runners/worker/operations.py", line 00, in   apache_beam.runners.worker.operations.ConsumerSet.receive   