Searched refs:_attempt_slice_recovery (Results 1 – 1 of 1) sorted by relevance
498 task_directive = self._attempt_slice_recovery(shard_state, tstate)788 def _attempt_slice_recovery(self, shard_state, tstate): member in MapperWorkerCallbackHandler