diff --git a/banzai/main.py b/banzai/main.py index 5279dd48..bd1c1fd5 100755 --- 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)