Searched refs:_TaskType (Results 1 – 4 of 4) sorted by relevance
40 class _TaskType(object): class99 return len(cluster_spec.as_dict().get(_TaskType.WORKER, [])) + len(100 cluster_spec.as_dict().get(_TaskType.CHIEF, []))178 if _TaskType.CHIEF in self._cluster_spec.jobs:179 task_type = _TaskType.CHIEF182 assert _TaskType.WORKER in self._cluster_spec.jobs183 task_type = _TaskType.WORKER197 self._task_type in [_TaskType.CHIEF, _TaskType.EVALUATOR, None]):202 if (_TaskType.CHIEF not in self._cluster_spec.jobs and203 self._task_type == _TaskType.WORKER and self._task_id == 0):[all …]
32 CHIEF = dc._TaskType.CHIEF33 EVALUATOR = dc._TaskType.EVALUATOR34 PS = dc._TaskType.PS35 WORKER = dc._TaskType.WORKER
53 CHIEF = distribute_coordinator._TaskType.CHIEF54 WORKER = distribute_coordinator._TaskType.WORKER55 PS = distribute_coordinator._TaskType.PS56 EVALUATOR = distribute_coordinator._TaskType.EVALUATOR
65 CHIEF = dc._TaskType.CHIEF66 EVALUATOR = dc._TaskType.EVALUATOR67 WORKER = dc._TaskType.WORKER68 PS = dc._TaskType.PS