def worker_input_generator(self):
        try:
            self.input_index, next_input = self.input_queue.get()
            yield next_input
        except TypeError:
            return
Only step our workers once.
dataset/ETHPy150Open gatoatigrado/vimap/vimap/testing.py/SerialWorkerRoutine.worker_input_generator