) File   "apache_beam/runners/worker/operations.py", line 000, in   apache_beam.runners.worker.operations.Operation.output   cython.cast(Receiver,   self.receivers[output_index]).receive(windowed_value) File   "apache_beam/runners/worker/operations.py", line 00, in   apache_beam.runners.worker.operations.ConsumerSet.receive   cython.cast(Operation, consumer).process(windowed_value) File   "apache_beam/runners/worker/operations.py", line 000, in   apache_beam.runners.worker.operations.DoOperation.process with   self.scoped_process_state: File   "apache_beam/runners/worker/operations.py", line 000, in   apache_beam.runners.worker.operations.DoOperation.process   self.dofn_receiver.receive(o) File "apache_beam/runners/common.py",   line 000, in apache_beam.runners.common.DoFnRunner.receive   self.process(windowed_value) File "apache_beam/runners/common.py",   line 000, in apache_beam.runners.common.DoFnRunner.process   self._reraise_augmented(exn) File "apache_beam/runners/common.py",   line 000, in apache_beam.runners.common.DoFnRunner._reraise_augmented   raise 