]> git.ipfire.org Git - pbs.git/commitdiff
hub: Call job.start() when starting jobs
authorMichael Tremer <michael.tremer@ipfire.org>
Tue, 21 Jun 2022 12:47:10 +0000 (12:47 +0000)
committerMichael Tremer <michael.tremer@ipfire.org>
Tue, 21 Jun 2022 12:47:10 +0000 (12:47 +0000)
Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
src/hub/queue.py

index f2d42ce90c4504e1d8aa068b5abd68b317454cc0..4e079555a28492cc6021ac5dd3babe13fb0db85a 100644 (file)
@@ -119,8 +119,9 @@ class QueueHandler(BackendMixin, HTTPBasicAuthMixin, tornado.websocket.WebSocket
        def assign_job(self, job):
                log.debug("Sending job %s to %s" % (job, self))
 
-               # Assign builder
-               job.builder = self.builder
+               # Start this job
+               with self.db.transaction():
+                       job.start(builder=self.builder)
 
                self.write_message({
                        "message" : "job",