Searched refs:_set_state (Results 1 – 1 of 1) sorted by relevance
530 task_directive = self._set_state(shard_state, tstate, task_directive)650 def _set_state(self, shard_state, tstate, task_directive): member in MapperWorkerCallbackHandler