Searched refs:_attempt_slice_retry (Results 1 – 1 of 1) sorted by relevance
688 task_directive = self._attempt_slice_retry(shard_state, tstate)866 def _attempt_slice_retry(self, shard_state, tstate): member in MapperWorkerCallbackHandler