def spool_input(self, close_if_done=True):
        self.qm.spool_input(self.all_input_serialized)

        workers = itertools.cycle(self.processes)

        while not self.qm.input_queue.empty():
            worker_proc = workers.next()
            worker_proc._target(*worker_proc._args, **worker_proc._kwargs)
Instead of just spooling input, immediately do the work too.
dataset/ETHPy150Open gatoatigrado/vimap/vimap/testing.py/SerialPool.spool_input