Searched refs:job_tasks (Results 1 – 11 of 11) sorted by relevance
79 job_tasks = job_string.split("|")[1].split(";")80 for i in range(len(job_tasks)):81 if not job_tasks[i]:84 job_def.tasks[i] = job_tasks[i]88 job_tasks[i], job_name)
288 job_tasks = {i: task for i, task in enumerate(tasks)}290 job_tasks = {i: task for i, task in tasks.items()}294 self._cluster_spec[job_name] = job_tasks354 ret[job] = self.job_tasks(job)433 def job_tasks(self, job_name): member in ClusterSpec
523 self.assertEqual(["ps0:2222", "ps1:2222"], cluster_spec.job_tasks("ps"))525 cluster_spec.job_tasks("worker"))527 cluster_spec.job_tasks("sparse"))529 cluster_spec.job_tasks("unknown")
367 job_tasks = cluster_spec.job_tasks(self.task_type)368 if not job_tasks:370 master = job_tasks[0]
163 len(cluster_spec.job_tasks(cluster_spec.jobs[0])) == 1)):
441 if len(jobs) == 1 and len(cluster_spec.job_tasks(jobs[0])) == 1:453 addresses = cluster_spec.job_tasks(task_type)
22 name: "job_tasks"
274 for _ in config.cluster_spec.job_tasks(job):
82 next_global_id += len(cluster_spec.job_tasks(t))
192 return prefix + self._cluster_spec.job_tasks(task_type)[task_id or 0]