Searched refs:task_directive (Results 1 – 1 of 1) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | handlers.py | 451 task_directive = self._try_acquire_lease(shard_state, tstate)
452 if task_directive in (self._TASK_DIRECTIVE.RETRY_TASK,
454 return self.__return(shard_state, tstate, task_directive)
455 assert task_directive == self._TASK_DIRECTIVE.PROCEED_TASK
459 task_directive = self._TASK_DIRECTIVE.ABORT_SHARD
460 return self.__return(shard_state, tstate, task_directive)
465 task_directive = self._TASK_DIRECTIVE.RETRY_SHARD
466 return self.__return(shard_state, tstate, task_directive)
495 return self.__return(shard_state, tstate, task_directive)
498 task_directive = self._attempt_slice_recovery(shard_state, tstate)
[all …]
|