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)
Get the source of a document by it's index, type and id.
dataset/ETHPy150Open gatoatigrado/vimap/vimap/testing.py/SerialPool.spool_input--crossover with--dataset/ETHPy150Open elastic/elasticsearch-py/elasticsearch/client/__init__.py/Elasticsearch.get_source