hub: Try to dispatch any jobs once a builder connects

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

diff --git a/src/hub/queue.py b/src/hub/queue.py
index 6873e490084885cfa444a9ec94ac275832394a87..11879c4f76b59a7cbe3856bebb990cea666ca856 100644 (file)
--- a/src/hub/queue.py
+++ b/src/hub/queue.py
@@ -85,7 +85,7 @@ class QueueHandler(BackendMixin, tornado.websocket.WebSocketHandler):
                return self.current_user
 
        @tornado.web.authenticated
-       def open(self):
+       async def open(self):
                logging.debug("Connection opened by %s" % self.builder)
 
                # Find any previous connections of this builder and close them
@@ -102,6 +102,9 @@ class QueueHandler(BackendMixin, tornado.websocket.WebSocketHandler):
                # Add this connection to the list
                connections.append(self)
 
+               # Dispatch any jobs immediately
+               await dispatch_jobs(self.backend)
+
        def on_close(self):
                logging.debug("Connection to %s closed" % self.builder)