Searched refs:_save_state_and_schedule_next (Results 1 – 1 of 1) sorted by relevance
531 self._save_state_and_schedule_next(shard_state, tstate, task_directive)696 def _save_state_and_schedule_next(self, shard_state, tstate, task_directive): member in MapperWorkerCallbackHandler