Searched refs:set_processed_counts (Results 1 – 2 of 2) sorted by relevance
637 def set_processed_counts(self, shards_processed, shards_status): member in MapreduceState715 state.set_processed_counts([], [])
1163 state.set_processed_counts(processed_counts, processed_status)