From: Michael Tremer <michael.tremer@ipfire.org>
Date: Thu, 9 Mar 2023 23:42:09 +0000 (+0000)
Subject: hub: Dispatch any jobs immediately
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=d98f756d2dec41e676e120099d0288c41c72c159;p=pbs.git

hub: Dispatch any jobs immediately

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

diff --git a/src/hub/builds.py b/src/hub/builds.py
index 666e6c01..e7b79a0a 100644
--- a/src/hub/builds.py
+++ b/src/hub/builds.py
@@ -24,6 +24,7 @@ import tornado.web
 from ..errors import NoSuchDistroError
 
 from .handlers import BaseHandler
+from . import queue
 
 class CreateHandler(BaseHandler):
 	async def post(self):
@@ -68,3 +69,6 @@ class CreateHandler(BaseHandler):
 
 		# Run dependency check on all jobs
 		await self.backend.jobs.depcheck(build.jobs)
+
+		# Try to dispatch jobs
+		await queue.dispatch_jobs(self.backend)
diff --git a/src/hub/jobs.py b/src/hub/jobs.py
index 865d77ca..67ebd7ae 100644
--- a/src/hub/jobs.py
+++ b/src/hub/jobs.py
@@ -24,6 +24,7 @@ import logging
 import tornado.websocket
 
 from .handlers import BaseHandler, BackendMixin
+from . import queue
 
 class BuilderHandler(BackendMixin, tornado.websocket.WebSocketHandler):
 	"""
@@ -101,3 +102,6 @@ class FinishedHandler(BaseHandler):
 			# Mark the job as finished
 			await job.finished(success=success,
 				logfile=logfile, packages=packages)
+
+		# Try to dispatch the next job
+		await queue.dispatch_jobs(self.backend)