diff --git a/app/celery_worker.py b/app/celery_worker.py
new file mode 100644
index 00000000..42a2c269
--- /dev/null
+++ 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!"