From 527c6c86ff5c0d9fc12439f4bbed1083c6c497f1 Mon Sep 17 00:00:00 2001 From: Christian Krakau-Louis Date: Sun, 9 Feb 2025 16:22:24 +0100 Subject: [PATCH] Create celery_worker.py --- app/celery_worker.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) create mode 100644 app/celery_worker.py 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!"