Remove routing key - seemed to be some issues routing messages.

LCOGT · Nov 11, 2024 · f427f15 · f427f15
1 parent c4f12e2
commit f427f15
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/banzai/main.py b/banzai/main.py
@@ -62,8 +62,7 @@ def on_message(self, body, message):
         else:
             queue_name = self.runtime_context.CELERY_TASK_QUEUE_NAME
         process_image.apply_async(args=(body, vars(self.runtime_context)),
-                                  queue=queue_name,
-                                  routing_key=f'{queue_name}#')
+                                  queue=queue_name)
         message.ack()  # acknowledge to the sender we got this message (it can be popped)