

def run(self, job_name, handler_spec, input_reader_spec, output_writer_spec=None, params=None, shards=None):
    mapreduce_id = control.start_map(job_name, handler_spec, input_reader_spec, (params or {
        
    }), mapreduce_parameters={
        'done_callback': self.get_callback_url(),
        'done_callback_method': 'GET',
        'pipeline_id': self.pipeline_id,
    }, shard_count=shards, output_writer_spec=output_writer_spec)
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url=('%s/detail?job_id=%s' % (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))

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