Searched refs:reset_for_retry (Results 1 – 2 of 2) sorted by relevance
776 def reset_for_retry(self, output_writer): member in TransientShardState973 def reset_for_retry(self): member in ShardState
854 shard_state.reset_for_retry()863 tstate.reset_for_retry(output_writer)