From dd8be4709c14306714491acf34a333fcd81170c2 Mon Sep 17 00:00:00 2001 From: Michael Tremer Date: Sun, 23 Oct 2022 18:02:47 +0000 Subject: [PATCH] hub: Log that we joined the queue Signed-off-by: Michael Tremer --- src/pakfire/hub.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/pakfire/hub.py b/src/pakfire/hub.py index 4d47965e3..79d5341fa 100644 --- a/src/pakfire/hub.py +++ b/src/pakfire/hub.py @@ -400,9 +400,14 @@ class Hub(object): on_message_callback = functools.partial( self._decode_json_message, job_received_callback) - return await self._request("GET", "/queue", websocket=True, ping=10, + # Join the queue + queue = await self._request("GET", "/queue", websocket=True, ping=10, on_message_callback=on_message_callback) + log.debug("Joined the queue") + + return queue + @staticmethod def _decode_json_message(callback, message): """ -- 2.47.3