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 666e6c01843d4c83a03f2e6a06ddbfb2090cef8f..e7b79a0afdcafa866de0e58d2b9edc07f1d93ae9 100644 (file)
--- 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 865d77ca00658697b24410dd6ac45325be4413dc..67ebd7aef16653bf6e7f837206e2d51c26a52648 100644 (file)
--- 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)