From: Michael Tremer <michael.tremer@ipfire.org>
Date: Tue, 21 Jun 2022 12:47:10 +0000 (+0000)
Subject: hub: Call job.start() when starting jobs
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=1561de02a72423e08fdb1745eb46048794f13272;p=pbs.git

hub: Call job.start() when starting jobs

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
---

diff --git a/src/hub/queue.py b/src/hub/queue.py
index f2d42ce9..4e079555 100644
--- a/src/hub/queue.py
+++ b/src/hub/queue.py
@@ -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",