class JobQueue(base.Object):
def __iter__(self):
- jobs = self.backend.jobs._get_jobs("SELECT jobs.* FROM jobs_queue queue \
+ jobs = self.backend.jobs._get_jobs("SELECT jobs.* FROM job_queue queue \
LEFT JOIN jobs ON queue.job_id = jobs.id")
return iter(jobs)
def __len__(self):
- res = self.db.get("SELECT COUNT(*) AS len FROM jobs_queue")
+ res = self.db.get("SELECT COUNT(*) AS len FROM job_queue")
return res.len
)
def get_length_for_arch(self, arch):
- res = self.db.get("SELECT COUNT(*) AS len FROM jobs_queue queue \
+ res = self.db.get("SELECT COUNT(*) AS len FROM job_queue queue \
LEFT JOIN jobs on queue.job_id = jobs.id \
WHERE jobs.arch = %s", arch)
Returns how long the jobs in the queue have been waiting on average
"""
res = self.db.get("SELECT AVG(NOW() - COALESCE(jobs.start_not_before, jobs.time_created)) AS avg \
- FROM jobs_queue queue LEFT JOIN jobs ON queue.job_id = jobs.id")
+ FROM job_queue queue LEFT JOIN jobs ON queue.job_id = jobs.id")
return res.avg
if not self.state == "pending":
return
- res = self.db.get("SELECT rank FROM jobs_queue WHERE job_id = %s", self.id)
+ res = self.db.get("SELECT rank FROM job_queue WHERE job_id = %s", self.id)
if res:
return res.rank