Update main.py

main.py

@@ -115,10 +115,15 @@ async def create_mission(request: Request):
     started_at = datetime.now().isoformat()
     plan = await plan_mission(task)
 
+    # ── Ordenar pipeline: analyst siempre antes que writer ──────────────────
+    delegates = plan.get("delegate", [])
+    PIPELINE_ORDER = ["analyst", "backend_dev", "frontend_dev", "writer", "image_agent"]
+    delegates = sorted(delegates, key=lambda k: PIPELINE_ORDER.index(k) if k in PIPELINE_ORDER else 99)
+
     results = []
     shared_context = {}
 
-    for agent_key in plan.get("delegate", []):
+    for agent_key in delegates:
         result = await run_specialized_agent(agent_key, task, context=shared_context)
         results.append(result)
         if result.get("success"):