Spaces:
Running
Running
Update main.py
Browse files
main.py
CHANGED
|
@@ -45,27 +45,26 @@ async def create_mission(request: Request):
|
|
| 45 |
# Ejecutar agentes delegados (con contexto compartido)
|
| 46 |
results = []
|
| 47 |
shared_context = {} # para pasar info entre agentes
|
| 48 |
-
|
| 49 |
for agent_key in plan.get("delegate", []):
|
| 50 |
# Pasar contexto acumulado
|
| 51 |
result = await run_specialized_agent(agent_key, task, context=shared_context)
|
| 52 |
results.append(result)
|
| 53 |
-
|
| 54 |
# Acumular respuesta para el siguiente agente
|
| 55 |
if result["success"]:
|
| 56 |
shared_context[agent_key] = result["response"]
|
| 57 |
-
|
| 58 |
-
# Buscar file_path en los resultados
|
| 59 |
file_path = None
|
| 60 |
for res in results:
|
| 61 |
if res.get("file_path"):
|
| 62 |
file_path = res["file_path"]
|
| 63 |
break
|
| 64 |
-
|
| 65 |
-
|
| 66 |
-
|
| 67 |
-
|
| 68 |
-
|
| 69 |
# Guardar en DB
|
| 70 |
from core.storage import save_mission
|
| 71 |
mission_data = {
|
|
@@ -75,17 +74,17 @@ async def create_mission(request: Request):
|
|
| 75 |
"plan": plan,
|
| 76 |
"results": results,
|
| 77 |
"doc_file": file_path,
|
| 78 |
-
"events": [] # puedes agregar logs aquí
|
| 79 |
}
|
| 80 |
save_mission(mission_data)
|
| 81 |
-
|
| 82 |
return JSONResponse({
|
| 83 |
"success": True,
|
| 84 |
"task": task,
|
| 85 |
"plan": plan,
|
| 86 |
"results": results,
|
| 87 |
"file_path": file_path,
|
| 88 |
-
"file_url": file_url
|
| 89 |
})
|
| 90 |
|
| 91 |
print("Mission Control v2 - Docker iniciado")
|
|
|
|
| 45 |
# Ejecutar agentes delegados (con contexto compartido)
|
| 46 |
results = []
|
| 47 |
shared_context = {} # para pasar info entre agentes
|
| 48 |
+
|
| 49 |
for agent_key in plan.get("delegate", []):
|
| 50 |
# Pasar contexto acumulado
|
| 51 |
result = await run_specialized_agent(agent_key, task, context=shared_context)
|
| 52 |
results.append(result)
|
| 53 |
+
|
| 54 |
# Acumular respuesta para el siguiente agente
|
| 55 |
if result["success"]:
|
| 56 |
shared_context[agent_key] = result["response"]
|
| 57 |
+
|
| 58 |
+
# Buscar file_path en cualquiera de los resultados (fuera del loop)
|
| 59 |
file_path = None
|
| 60 |
for res in results:
|
| 61 |
if res.get("file_path"):
|
| 62 |
file_path = res["file_path"]
|
| 63 |
break
|
| 64 |
+
|
| 65 |
+
# Crear URL de descarga relativa (solo si hay archivo)
|
| 66 |
+
file_url = f"/data/docs/{file_path}" if file_path else None
|
| 67 |
+
|
|
|
|
| 68 |
# Guardar en DB
|
| 69 |
from core.storage import save_mission
|
| 70 |
mission_data = {
|
|
|
|
| 74 |
"plan": plan,
|
| 75 |
"results": results,
|
| 76 |
"doc_file": file_path,
|
| 77 |
+
"events": [] # puedes agregar logs aquí si quieres
|
| 78 |
}
|
| 79 |
save_mission(mission_data)
|
| 80 |
+
|
| 81 |
return JSONResponse({
|
| 82 |
"success": True,
|
| 83 |
"task": task,
|
| 84 |
"plan": plan,
|
| 85 |
"results": results,
|
| 86 |
"file_path": file_path,
|
| 87 |
+
"file_url": file_url # ← para que el frontend lo use
|
| 88 |
})
|
| 89 |
|
| 90 |
print("Mission Control v2 - Docker iniciado")
|