Searched refs:mr_id (Results 1 – 2 of 2) sorted by relevance
147 mr_id = self.request.headers[util._MR_ID_TASK_HEADER]150 model.MapreduceState.get_key_by_job_id(mr_id)])433 mr_id = self.request.headers[util._MR_ID_TASK_HEADER]434 spec = model.MapreduceSpec._get_mapreduce_spec(mr_id)437 model.MapreduceControl.get_key_by_job_id(mr_id),1079 mr_id = self.request.headers[util._MR_ID_TASK_HEADER]1080 state = model.MapreduceState.get_by_job_id(mr_id)1379 mr_id = self.request.get("mapreduce_id")1381 logging.info("Processing kickoff for job %s", mr_id)1382 state = model.MapreduceState.get_by_job_id(mr_id)[all …]
543 def _get_mapreduce_spec(cls, mr_id): argument545 key = 'GAE-MR-spec: %s' % mr_id549 state = MapreduceState.get_by_job_id(mr_id)