Lines Matching full:group
29 'job-group-(?P<id>\d+)')
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:
75 # Lets block until the group is killed so we know it is completed
77 while group.status not in [job_group.STATUS_SUCCEEDED,
84 group = job_.group
87 # We need to perform an action only if the group hasn't already failed.
88 if group.status != job_group.STATUS_FAILED:
90 # We have a failed job, abort the job group
91 group.status = job_group.STATUS_FAILED
92 if group.cleanup_on_failure:
93 for job_ in group.jobs:
95 # instead of the whole job group.
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: