From 3412e8a92cdde3ff7239f7f2ff83863f08f03cf2 Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Fri, 22 Sep 2023 10:47:35 -0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A7=20chore(celery=5Fapp.py):=20modify?= =?UTF-8?q?=20make=5Fcelery=20function=20signature=20to=20accept=20a=20con?= =?UTF-8?q?fig=20parameter=20=F0=9F=94=A7=20chore(celery=5Fapp.py):=20upda?= =?UTF-8?q?te=20celery=5Fapp.config=5Ffrom=5Fobject=20argument=20to=20use?= =?UTF-8?q?=20the=20config=20parameter=20passed=20to=20make=5Fcelery=20fun?= =?UTF-8?q?ction?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/backend/langflow/core/celery_app.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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")