

def callback(self):
    mapreduce_id = self.outputs.job_id.value
    mapreduce_state = model.MapreduceState.get_by_job_id(mapreduce_id)
    mapper_spec = mapreduce_state.mapreduce_spec.mapper
    files = None
    output_writer_class = mapper_spec.output_writer_class()
    if output_writer_class:
        files = output_writer_class.get_filenames(mapreduce_state)
    self.fill(self.outputs.counters, mapreduce_state.counters_map.to_dict())
    self.complete(files)

dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/ext/mapreduce/mapper_pipeline.py MapperPipeline.callback/original