fix: trying librabbitmq for celery backend!

TogetherCrew · Jun 26, 2024 · c6bc0c0 · c6bc0c0
1 parent de9ca16
commit c6bc0c0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/celery_app/server.py b/celery_app/server.py
@@ -7,5 +7,5 @@
 host = rabbit_creds["host"]
 port = rabbit_creds["port"]
 
-app = Celery("celery_app/tasks", broker=f"pyamqp://{user}:{password}@{host}:{port}//")
+app = Celery("celery_app/tasks", broker=f"librabbitmq://{user}:{password}@{host}:{port}//")
 app.autodiscover_tasks(["celery_app"])