def pull_next_batch(self):
        self.worker_go.wait()
        batch, future = self.worker_work
        self.worker_work = None
        self.worker_go.clear()
        return batch, future
Worker calls this method to get the next batch/future.
dataset/ETHPy150Open membase/membase-cli/pump.py/Sink.pull_next_batch