Searched refs:shard_states (Results 1 – 2 of 2) sorted by relevance
1120 shard_states = model.ShardState.find_all_by_mapreduce_state(state)1121 self._update_state_from_shard_states(state, shard_states, control)1127 def _update_state_from_shard_states(self, state, shard_states, control): argument1143 for s in shard_states:1537 shard_states = []1541 shard_states.append(shard_state)1544 existing_shard_states = db.get(shard.key() for shard in shard_states)1550 db.put((shard for shard in shard_states1558 for shard_number, shard_state in enumerate(shard_states):1576 shard_states[shard_number])
495 shard_states = model.ShardState.find_all_by_mapreduce_state(mapreduce_state)496 for x, shard_state in enumerate(shard_states):