diff --git a/src/backend/langflow/core/celery_app.py b/src/backend/langflow/core/celery_app.py
index 699fc3e14..85e2bc2d2 100644
--- a/src/backend/langflow/core/celery_app.py
+++ b/src/backend/langflow/core/celery_app.py
@@ -1,11 +1,11 @@
 from celery import Celery  # type: ignore
 
 
-def make_celery(app_name: str):
+def make_celery(app_name: str, config: str):
     celery_app = Celery(app_name)
-    celery_app.config_from_object("langflow.core.celeryconfig")
+    celery_app.config_from_object(config)
     celery_app.conf.task_routes = {"langflow.worker.tasks.*": {"queue": "langflow"}}
     return celery_app
 
 
-celery_app = make_celery("langflow")
+celery_app = make_celery("langflow", "langflow.core.celeryconfig")