def worker_input_generator(self):
        while True:
            try:
                x = self.input_queue.get(timeout=_IDLE_TIMEOUT)
                if x is None:
                    return
                if self.input_index is not None:
                    vimap.exception_handling.print_warning(
                        "Didn't produce an output for input!",
                        input_index=self.input_index)
                self.input_index, z = x
                self.debug("Got input #{0}", self.input_index)
                yield z
            except multiprocessing.queues.Empty:
                # print("Waiting")
                pass
            except IOError:
                print(
                    "Worker error getting item from input queue",
                    file=sys.stderr)
                raise
Call this on the worker processes: yields input.
dataset/ETHPy150Open gatoatigrado/vimap/vimap/real_worker_routine.py/WorkerRoutine.worker_input_generator