Create app/agents/orchestrator.py

app/agents/orchestrator.py

@@ -0,0 +1,21 @@
+# app/agents/orchestrator.py
+
+from app.core.router import route_agent
+from app.workers.tasks import enqueue_task
+
+def process_request(prompt: str, user_id: str):
+    agent = route_agent(prompt)
+
+    task = {
+        "agent": agent,
+        "prompt": prompt,
+        "user_id": user_id
+    }
+
+    task_id = enqueue_task(task)
+
+    return {
+        "status": "queued",
+        "task_id": task_id,
+        "agent": agent
+    }