mapreduce/handlers.py
def reschedule(self, mapreduce_spec, input_reader):
    """Reschedule worker task to continue scanning work.

    Args:
      mapreduce_spec: mapreduce specification.
      input_reader: remaining input reader to process.
    """
    MapperWorkerCallbackHandler.schedule_slice(
        self.base_path(), mapreduce_spec, self.shard_id(),
        self.slice_id() + 1, input_reader)
Reschedule worker task to continue scanning work.

    Args:
      mapreduce_spec: mapreduce specification.
      input_reader: remaining input reader to process.
    
Reschedule worker task to continue scanning work.
Reschedule worker task to continue scanning work .
def reschedule(self, mapreduce_spec, input_reader):
    MapperWorkerCallbackHandler.schedule_slice(
        self.base_path(), mapreduce_spec, self.shard_id(),
        self.slice_id() + 1, input_reader)
def reschedule ( self , mapreduce_spec , input_reader ) : MapperWorkerCallbackHandler . schedule_slice ( self . base_path ( ) , mapreduce_spec , self . shard_id ( ) , self . slice_id ( ) + 1 , input_reader )
Reschedule worker task to continue scanning work.
Reschedule worker task to continue scanning work .
"""Reschedule worker task to continue scanning work.

    Args:
      mapreduce_spec: mapreduce specification.
      input_reader: remaining input reader to process.
    """
self
mapreduce_spec
None
input_reader
remaining input reader to process.
remaining input reader to process .