Fix thread arg passing

alephdata · Jul 30, 2024 · 008806a · 008806a
1 parent 429b1a1
commit 008806a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -711,7 +711,7 @@ def consume_queue(queue):
                     self.on_message(channel, method, properties, body)
 
         for queue in self.queues:
-            thread = threading.Thread(target=consume_queue, queue=queue)
+            thread = threading.Thread(target=consume_queue, args=(queue,))
             thread.daemon = True
             thread.start()
             threads.append(thread)