| from celery import Celery | |
| def make_celery(app_name: str, config: str) -> Celery: | |
| celery_app = Celery(app_name) | |
| celery_app.config_from_object(config) | |
| celery_app.conf.task_routes = {"langflow.worker.tasks.*": {"queue": "langflow"}} | |
| return celery_app | |
| celery_app = make_celery("langflow", "langflow.core.celeryconfig") | |