Create celery_worker.py

christianlouis · Feb 9, 2025 · 6eac722 · 6eac722
1 parent 37b3876
commit 6eac722
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/app/celery_worker.py b/app/celery_worker.py
@@ -0,0 +1,14 @@
+#!/usr/bin/env python3
+
+from celery import Celery
+from .config import settings
+
+celery = Celery("document_processor", broker=settings.redis_url, backend=settings.redis_url)
+
+celery.conf.task_routes = {
+    "app.tasks.*": {"queue": "default"},
+}
+
+@celery.task
+def test_task():
+    return "Celery is working!"