Searched refs:job_tasks (Results 1 – 10 of 10) 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)
294 job_tasks = {i: task for i, task in enumerate(tasks)}296 job_tasks = {i: task for i, task in tasks.items()}300 self._cluster_spec[job_name] = job_tasks363 ret[job] = self.job_tasks(job)442 def job_tasks(self, job_name): member in ClusterSpec
575 self.assertEqual(["ps0:2222", "ps1:2222"], cluster_spec.job_tasks("ps"))577 cluster_spec.job_tasks("worker"))579 cluster_spec.job_tasks("sparse"))581 cluster_spec.job_tasks("unknown")
266 job_tasks = cluster_spec.job_tasks(self.task_type)267 if not job_tasks:269 master = job_tasks[0]
22 name: "job_tasks"
194 len(cluster_spec.job_tasks(cluster_spec.jobs[0])) == 1)):
200 len(cluster_spec.job_tasks(cluster_spec.jobs[0])) == 1)):
82 next_global_id += len(cluster_spec.job_tasks(t))
192 return prefix + self._cluster_spec.job_tasks(task_type)[task_id or 0]