Searched refs:job_tasks (Results 1 – 9 of 9) 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)
210 job_tasks = cluster_spec.job_tasks(self.task_type)211 if not job_tasks:213 master = job_tasks[0]
168 len(cluster_spec.job_tasks(cluster_spec.jobs[0])) == 1)):
289 job_tasks = {i: task for i, task in enumerate(tasks)}291 job_tasks = {i: task for i, task in tasks.items()}295 self._cluster_spec[job_name] = job_tasks358 ret[job] = self.job_tasks(job)437 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")
22 name: "job_tasks"
82 next_global_id += len(cluster_spec.job_tasks(t))
192 return prefix + self._cluster_spec.job_tasks(task_type)[task_id or 0]