

def flush(self):
    'Flush all information recorded in context.'
    for pool in self._pools.values():
        pool.flush()
    if self.shard_state:
        self.shard_state.put()

dataset/ETHPy150Open livid/v2ex/mapreduce/context.py Context.flush/original