diff --git a/src/backend/langflow/core/__init__.py b/src/backend/langflow/core/__init__.py
new file mode 100644
index 000000000..e69de29bb
diff --git a/src/backend/langflow/core/celery_app.py b/src/backend/langflow/core/celery_app.py
new file mode 100644
index 000000000..7b89a05ab
--- /dev/null
+++ b/src/backend/langflow/core/celery_app.py
@@ -0,0 +1,7 @@
+from celery import Celery
+
+celery_app = Celery(
+    "langflow", broker="redis://queue:6379/0", backend="redis://queue:6379/0"
+)
+# command: celery -A langflow.worker.celery_app worker --loglevel=INFO
+celery_app.conf.task_routes = {"langflow.worker.tasks.*": {"queue": "langflow"}}
diff --git a/src/backend/langflow/core/celeryconfig.py b/src/backend/langflow/core/celeryconfig.py
new file mode 100644
index 000000000..647a7f93d
--- /dev/null
+++ b/src/backend/langflow/core/celeryconfig.py
@@ -0,0 +1,7 @@
+# celeryconfig.py
+import os
+
+broker_url = os.environ.get("BROKER_URL", "redis://localhost:6379/0")
+result_backend = os.environ.get("RESULT_BACKEND", "redis://localhost:6379/0")
+# tasks should be json or pickle
+accept_content = ["json", "pickle"]