Searched refs:MapreduceState (Results 1 – 6 of 6) sorted by relevance
262 if (map_result_status == model.MapreduceState.RESULT_ABORTED or263 reduce_result_status == model.MapreduceState.RESULT_ABORTED):264 result_status = model.MapreduceState.RESULT_ABORTED265 elif (map_result_status == model.MapreduceState.RESULT_FAILED or266 reduce_result_status == model.MapreduceState.RESULT_FAILED):267 result_status = model.MapreduceState.RESULT_FAILED269 result_status = model.MapreduceState.RESULT_SUCCESS274 if result_status == model.MapreduceState.RESULT_SUCCESS:
114 mapreduce_state = model.MapreduceState.get_by_job_id(mapreduce_id)115 if mapreduce_state.result_status != model.MapreduceState.RESULT_SUCCESS:124 mapreduce_state.result_status == model.MapreduceState.RESULT_SUCCESS):
150 model.MapreduceState.get_key_by_job_id(mr_id)])1080 state = model.MapreduceState.get_by_job_id(mr_id)1085 state.result_status = model.MapreduceState.RESULT_FAILED1105 model.MapreduceState.get_key_by_job_id(spec.mapreduce_id),1186 state.result_status = model.MapreduceState.RESULT_FAILED1190 state.result_status = model.MapreduceState.RESULT_ABORTED1192 state.result_status = model.MapreduceState.RESULT_SUCCESS1199 fresh_state = model.MapreduceState.get_by_job_id(spec.mapreduce_id)1230 mapreduce_state.result_status == model.MapreduceState.RESULT_SUCCESS):1260 fresh_state = model.MapreduceState.get_by_job_id([all …]
318 query = model.MapreduceState.all()360 job = model.MapreduceState.get_by_key_name(mapreduce_id)
549 state = MapreduceState.get_by_job_id(mr_id)556 class MapreduceState(db.Model): class712 mapreduce_id = MapreduceState.new_mapreduce_id()713 state = MapreduceState(key_name=mapreduce_id,
23 FAILED = model.MapreduceState.RESULT_FAILED24 ABORTED = model.MapreduceState.RESULT_ABORTED25 SUCCESS = model.MapreduceState.RESULT_SUCCESS176 state = model.MapreduceState.get_by_job_id(job_id)201 state = model.MapreduceState.create_new(job_config.job_id)