cristiano.hoshikawa/agent_platform_oci
1
2
Fork 0
mirror of https://github.com/hoshikawa2/agent_platform_oci.git synced 2026-11-06 03:14:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

new feature: frontend with separated responses

Browse Source
This commit is contained in:
Cristiano Hoshikawa
2026-09-11 09:33:50 -03:00
parent f62c7993bb
commit f00c2f721a
40 changed files with 248 additions and 330 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Tuning-Performance/Authentication/agent_template_backend_authentication/app/main.py
View File

@@ -369,6 +369,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Authentication/agent_template_backend_authentication/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Authentication/agent_template_backend_authentication/app/workflows/agent_graph.py
View File

@@ -490,6 +490,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -569,6 +570,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -662,6 +664,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Deterministic_Transactional_Workflow/agent_template_backend/app/main.py
View File

@@ -363,6 +363,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Deterministic_Transactional_Workflow/agent_template_backend/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Deterministic_Transactional_Workflow/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -490,6 +490,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -569,6 +570,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -662,6 +664,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/External_Guardrails_Judges/agent_template_backend/app/main.py
View File

@@ -358,6 +358,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/External_Guardrails_Judges/agent_template_backend/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/External_Guardrails_Judges/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -488,6 +488,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -567,6 +568,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -660,6 +662,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Long_Term_Memory/templates/agent_template_backend/app/main.py
View File

@@ -363,6 +363,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Long_Term_Memory/templates/agent_template_backend/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Long_Term_Memory/templates/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -490,6 +490,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -569,6 +570,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -662,6 +664,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Normal/templates/agent_template_backend/app/main.py
View File

@@ -358,6 +358,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Normal/templates/agent_template_backend/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Normal/templates/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -488,6 +488,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -567,6 +568,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -660,6 +662,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Normal/templates/agent_template_backend_day_zero/app/main.py
View File

@@ -358,6 +358,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Normal/templates/agent_template_backend_day_zero/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Normal/templates/agent_template_backend_day_zero/app/workflows/agent_graph.py
View File

@@ -488,6 +488,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -567,6 +568,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -660,6 +662,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Route_Stickness/templates/agent_template_backend/app/main.py
View File

@@ -358,6 +358,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Route_Stickness/templates/agent_template_backend/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Route_Stickness/templates/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -488,6 +488,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -567,6 +568,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -660,6 +662,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Route_Stickness/templates/agent_template_backend_day_zero/app/main.py
View File

@@ -358,6 +358,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Route_Stickness/templates/agent_template_backend_day_zero/app/state.py
View File

@@ -36,6 +36,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Route_Stickness/templates/agent_template_backend_day_zero/app/workflows/agent_graph.py
View File

@@ -488,6 +488,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -567,6 +568,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -660,6 +662,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Transaction_Evidence/agent_template_backend/app/main.py
View File

@@ -457,6 +457,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Transaction_Evidence/agent_template_backend/app/state.py
View File

@@ -39,6 +39,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Transaction_Evidence/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -490,6 +490,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -569,6 +570,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -662,6 +664,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])

2
Tuning-Performance/Transaction_Pre_Validation/agent_template_backend/app/main.py
View File

@@ -457,6 +457,8 @@ async def _process_gateway_message(req: GatewayRequest, emit_sse: bool = False)
"route": result.get("route"),
"intent": result.get("intent"),
"route_decision": result.get("route_decision"),
"supervisor_results": result.get("supervisor_results") or [],
"agent_responses": result.get("agent_responses") or result.get("supervisor_results") or [],
"domain": result.get("domain"),
"mcp_tools": result.get("mcp_tools"),
"mcp_results": result.get("mcp_results"),

1
Tuning-Performance/Transaction_Pre_Validation/agent_template_backend/app/state.py
View File

@@ -40,6 +40,7 @@ class AgentState(TypedDict, total=False):
missing_parameters: list[str]
supervisor_plan: dict[str, Any]
supervisor_results: list[dict[str, Any]]
agent_responses: list[dict[str, Any]]
pending_topics: list[dict[str, Any]]
handled_topics: list[dict[str, Any]]
active_agent: str

3
Tuning-Performance/Transaction_Pre_Validation/agent_template_backend/app/workflows/agent_graph.py
View File

@@ -490,6 +490,7 @@ class AgentWorkflow:
return {
"answer": answer,
"supervisor_results": partials,
"agent_responses": partials,
"mcp_results": mcp_results,
"next_state": "SUPERVISOR_ACTIVE",
}
@@ -569,6 +570,7 @@ class AgentWorkflow:
"final_answer": candidate,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"output_guardrails_already_applied": False,
@@ -662,6 +664,7 @@ class AgentWorkflow:
"output_guardrails_already_applied": True,
"pending_topics": drained.pending_topics,
"handled_topics": drained.handled_topics,
"agent_responses": drained.agent_responses,
"mcp_results": drained.mcp_results,
"rag_results": drained.rag_results,
"guardrail_decisions": state.get("guardrail_decisions", [])