Searched refs:result_status (Results 1 – 10 of 10) sorted by relevance
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
D | mapreduce_pipeline.py | 239 yield _ReturnPipeline(map_pipeline.result_status, 240 reducer_pipeline.result_status, 264 result_status = model.MapreduceState.RESULT_ABORTED 267 result_status = model.MapreduceState.RESULT_FAILED 269 result_status = model.MapreduceState.RESULT_SUCCESS 271 self.fill(self.outputs.result_status, result_status) 274 if result_status == model.MapreduceState.RESULT_SUCCESS:
|
D | mapper_pipeline.py | 115 if mapreduce_state.result_status != model.MapreduceState.RESULT_SUCCESS: 117 mapreduce_id, mapreduce_state.result_status)) 124 mapreduce_state.result_status == model.MapreduceState.RESULT_SUCCESS): 127 self.fill(self.outputs.result_status, mapreduce_state.result_status)
|
D | status.py | 346 if job.result_status: 347 out["result_status"] = job.result_status 378 self.json_response["result_status"] = job.result_status 384 "result_status": shard.result_status,
|
D | model.py | 600 result_status = db.StringProperty(required=False, choices=_RESULTS) variable in MapreduceState 933 result_status = db.StringProperty(choices=_RESULTS, indexed=False) variable in ShardState 952 if self.result_status: 953 kv["result_status"] = self.result_status 978 self.result_status = None 1006 self.result_status = self.RESULT_FAILED 1010 self.result_status = self.RESULT_ABORTED 1020 self.result_status = self.RESULT_SUCCESS
|
D | handlers.py | 1085 state.result_status = model.MapreduceState.RESULT_FAILED 1149 if s.result_status == model.ShardState.RESULT_SUCCESS: 1151 elif s.result_status == model.ShardState.RESULT_ABORTED: 1154 elif s.result_status == model.ShardState.RESULT_FAILED: 1186 state.result_status = model.MapreduceState.RESULT_FAILED 1190 state.result_status = model.MapreduceState.RESULT_ABORTED 1192 state.result_status = model.MapreduceState.RESULT_SUCCESS 1230 mapreduce_state.result_status == model.MapreduceState.RESULT_SUCCESS): 1278 mapreduce_spec.mapreduce_id, mapreduce_state.result_status) 1392 state.result_status = model.MapreduceState.RESULT_SUCCESS [all …]
|
D | output_writers.py | 643 if shard.result_status == model.ShardState.RESULT_SUCCESS:
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/static/ |
D | status.js | 324 var status = (job.active ? 'running' : job.result_status) || 'unknown'; 548 var status = (detail.active ? 'running' : detail.result_status) || 'unknown'; 661 var status = (shard.active ? 'running' : shard.result_status) || 'unknown';
|
/external/autotest/server/cros/dynamic_suite/ |
D | suite_unittest.py | 446 result_status='FAIL'): argument 459 test_report = self._get_bad_test_report(result_status) 605 def _get_bad_test_report(self, result_status='FAIL'): argument 617 return test_report(predicates(result_status, 'bad_test', 749 will_file_bug=True, result_status='WARN')
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
D | map_job_control.py | 67 return self._state.result_status
|
/external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
D | pipeline.py | 1075 result_status): argument 1088 self._result_status = result_status 1119 result_status = _PipelineRecord.RUN 1121 result_status = _PipelineRecord.ABORTED 1124 context, pipeline_key, root_pipeline_key, caller_output, result_status)
|