From: Michael Tremer <michael.tremer@ipfire.org>
Date: Sun, 23 Oct 2022 18:02:47 +0000 (+0000)
Subject: hub: Log that we joined the queue
X-Git-Tag: 0.9.28~232
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=dd8be4709c14306714491acf34a333fcd81170c2;p=pakfire.git

hub: Log that we joined the queue

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

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):
 		"""