Searched refs:_state_to_task (Results 1 – 1 of 1) sorted by relevance
731 task = self._state_to_task(tstate, shard_state)736 task = self._state_to_task(tstate, shard_state)740 task = self._state_to_task(tstate, shard_state, countdown=countdown)940 def _state_to_task(cls, member in MapperWorkerCallbackHandler1049 task = cls._state_to_task(tstate, shard_state, eta, countdown)1571 task = MapperWorkerCallbackHandler._state_to_task(