93       for job_ in self.all_jobs:
94         self._KillJob(job_.id)
113     for job_ in self.all_jobs:
114       if job_.id == job_id:
115         return job_
123     for job_ in self.ready_jobs:
124       if job_.id == job_id:
125         self.ready_jobs.remove(job_)
128   def AddJob(self, job_):  argument
130       job_.id = self._id_producer.GetNextId()
132       self.all_jobs.append(job_)
134       if job_.is_ready:
135         self.ready_jobs.append(job_)
139     return job_.id
141   def CleanUpJob(self, job_):  argument
143       if job_.id in self.job_executer_mapping:
144         self.job_executer_mapping[job_.id].CleanUpWorkDir()
145         del self.job_executer_mapping[job_.id]
148   def NotifyJobComplete(self, job_):  argument
149     self.machine_manager.ReturnMachines(job_.machines)
152       self._logger.debug('Handling %r completion event.', job_)
154       if job_.status == job.STATUS_SUCCEEDED:
155         for succ in job_.successors: