Create app/workers/tasks.py

app/workers/tasks.py

@@ -0,0 +1,21 @@
+# app/workers/tasks.py
+
+import redis
+import json
+import uuid
+import os
+
+r = redis.Redis(
+    host=os.getenv("REDIS_HOST", "localhost"),
+    port=int(os.getenv("REDIS_PORT", 6379)),
+    password=os.getenv("REDIS_PASSWORD", None),
+    decode_responses=True
+)
+
+def enqueue_task(task: dict):
+    task_id = str(uuid.uuid4())
+    task["task_id"] = task_id
+
+    r.lpush("tasks", json.dumps(task))
+
+    return task_id