]> git.ipfire.org Git - pbs.git/commitdiff
jobs: Fix name of job queue view
authorMichael Tremer <michael.tremer@ipfire.org>
Sun, 29 May 2022 12:43:24 +0000 (12:43 +0000)
committerMichael Tremer <michael.tremer@ipfire.org>
Sun, 29 May 2022 12:43:24 +0000 (12:43 +0000)
Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
src/buildservice/jobqueue.py
src/buildservice/jobs.py

index 60b736669a679953af50c310343e759ca2b51460..a46d377180537eac4397a753973ccdcddc8da6e2 100644 (file)
@@ -12,13 +12,13 @@ PENDING_STATE = "pending"
 
 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
 
@@ -40,7 +40,7 @@ class JobQueue(base.Object):
                )
 
        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)
 
@@ -52,7 +52,7 @@ class JobQueue(base.Object):
                        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
 
index ab0ea4cc3737c64486890bd6949dcb861269a616..462fc9d353a4a52d992af804f3b8a3a1973af4d4 100644 (file)
@@ -178,7 +178,7 @@ class Job(base.DataObject):
                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