Lines Matching refs:group
35 for group in self.all_job_groups:
36 if group.id == group_id:
37 return group
45 def AddJobGroup(self, group): argument
47 group.id = self._id_producer.GetNextId()
49 self._logger.debug('Creating runtime environment for %r.', group)
52 cmd.RmTree(group.home_dir), cmd.MakeDir(group.home_dir)))
55 self.all_job_groups.append(group)
57 for job_ in group.jobs:
60 group.status = job_group.STATUS_EXECUTING
62 self._logger.info('Added %r to queue.', group)
64 return group.id
66 def KillJobGroup(self, group): argument
68 self._logger.debug('Killing all jobs that belong to %r.', group)
70 for job_ in group.jobs:
77 while group.status not in [job_group.STATUS_SUCCEEDED,
84 group = job_.group
88 if group.status != job_group.STATUS_FAILED:
91 group.status = job_group.STATUS_FAILED
92 if group.cleanup_on_failure:
93 for job_ in group.jobs:
102 for other_job in group.jobs:
108 if finished and group.status != job_group.STATUS_SUCCEEDED:
113 group.status = job_group.STATUS_SUCCEEDED
114 if group.cleanup_on_completion:
115 for job_ in group.jobs: