Searched refs:_attempt_shard_retry (Results 1 – 1 of 1) sorted by relevance
690 task_directive = self._attempt_shard_retry(shard_state, tstate)828 def _attempt_shard_retry(self, shard_state, tstate): member in MapperWorkerCallbackHandler