Searched refs:ShardState (Results 1 – 6 of 6) sorted by relevance
149 model.ShardState.get_key_by_shard_id(shard_id),268 fresh_state = model.ShardState.get_by_shard_id(tstate.shard_id)361 fresh_state = model.ShardState.get_by_shard_id(shard_state.shard_id)436 model.ShardState.get_key_by_shard_id(shard_id),752 fresh_shard_state = model.ShardState.get_by_shard_id(tstate.shard_id)1088 for ss in model.ShardState.find_all_by_mapreduce_state(state):1093 if len(puts) > model.ShardState._MAX_STATES_IN_MEMORY:1120 shard_states = model.ShardState.find_all_by_mapreduce_state(state)1149 if s.result_status == model.ShardState.RESULT_SUCCESS:1151 elif s.result_status == model.ShardState.RESULT_ABORTED:[all …]
381 for shard in model.ShardState.find_all_by_mapreduce_state(job):
642 for shard in model.ShardState.find_all_by_mapreduce_state(mapreduce_state):643 if shard.result_status == model.ShardState.RESULT_SUCCESS:
495 shard_states = model.ShardState.find_all_by_mapreduce_state(mapreduce_state)
858 class ShardState(db.Model): class
110 ss = model.ShardState.find_all_by_mapreduce_state(self._state)