From 206fbe39f96513c3b2fd340784bf2077bb587d9e Mon Sep 17 00:00:00 2001 From: Matt Daily Date: Tue, 12 Nov 2024 14:45:33 -0800 Subject: [PATCH] Retry with routing key without the # wildcard. --- banzai/main.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/banzai/main.py b/banzai/main.py index bd1c1fd5..470ed81b 100755 --- a/banzai/main.py +++ b/banzai/main.py @@ -61,8 +61,10 @@ def on_message(self, body, message): queue_name = self.runtime_context.LARGE_WORKER_QUEUE else: queue_name = self.runtime_context.CELERY_TASK_QUEUE_NAME + logger.info(f'Processing {body["filename"]} on queue {queue_name}. Routing key: {queue_name}', extra_tags={'filename': body['filename']}) process_image.apply_async(args=(body, vars(self.runtime_context)), - queue=queue_name) + queue=queue_name, + routing_key=queue_name) message.ack() # acknowledge to the sender we got this message (it can be popped)