'Reschedule worker task to continue scanning work.
Args:
mapreduce_spec: mapreduce specification.
input_reader: remaining input reader to process.'

def reschedule(self, mapreduce_spec, input_reader):

    MapperWorkerCallbackHandler.schedule_slice(self.base_path(), mapreduce_spec, self.shard_id(), (self.slice_id() + 1), input_reader)
