Searched refs:CHIEF (Results 1 – 4 of 4) sorted by relevance
43 CHIEF = "chief" variable in _TaskType100 cluster_spec.as_dict().get(_TaskType.CHIEF, []))178 if _TaskType.CHIEF in self._cluster_spec.jobs:179 task_type = _TaskType.CHIEF197 self._task_type in [_TaskType.CHIEF, _TaskType.EVALUATOR, None]):202 if (_TaskType.CHIEF not in self._cluster_spec.jobs and472 for task_type in [_TaskType.CHIEF, _TaskType.WORKER]:857 if task_type in [_TaskType.CHIEF, _TaskType.WORKER]:
32 CHIEF = dc._TaskType.CHIEF variable108 config._cluster_spec, chief_task_type=CHIEF)113 chief_task_type=CHIEF)
56 CHIEF = distribute_coordinator._TaskType.CHIEF variable207 cluster_spec[CHIEF] = ["localhost:%s" % portpicker.pick_unused_port()]539 cluster_spec[CHIEF] = ["fake_chief"]550 self.assertTrue(CHIEF in self._worker_context)552 self.assertEqual(len(self._worker_context[CHIEF]), 1)557 self.assertEqual(self._worker_context[CHIEF][0],
61 CHIEF = run_config.TaskType.CHIEF variable443 if CHIEF in d.extended._cluster_spec.as_dict():829 cls._default_target = 'grpc://' + cls._cluster_spec[CHIEF][0]