mapreduce/context.py
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()
Flush all information recorded in context.
Flush all information recorded in context.
Flush all information recorded in context .
def flush(self):
    for pool in self._pools.values():
      pool.flush()
    if self.shard_state:
      self.shard_state.put()
def flush ( self ) : for pool in self . _pools . values ( ) : pool . flush ( ) if self . shard_state : self . shard_state . put ( )
Flush all information recorded in context.
Flush all information recorded in context .
"""Flush all information recorded in context."""
self