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.
    
mapreduce/handlers.py