feat(routing): surface priority and routingConfidence in routing decisions

- Extend frontend RoutingDecision type with priority and routingConfidence fields
- Pass priority and routing_confidence through SSE in pipeline.py (live events)
- Pass priority and routing_confidence through agent_events.py (state snapshots)

Author: Siddharth-Khattar

backend/app/services/agent_events.py

@@ -161,7 +161,10 @@ async def publish_agent_event(
     if "type" not in data_to_send:
         data_to_send["type"] = event_type.value
 
-    event: SSEEvent = {"event": event_type.value, "data": json.dumps(data_to_send)}
+    event: SSEEvent = {
+        "event": event_type.value,
+        "data": json.dumps(data_to_send),
+    }
     _event_buffer[case_id].append(event)
     subscribers = _agent_subscribers.get(case_id, [])
     for queue in subscribers:
@@ -539,7 +542,9 @@ def build_execution_metadata(
         "inputTokens": execution.input_tokens or 0,
         "outputTokens": execution.output_tokens or 0,
         "durationMs": duration_ms or 0,
-        "startedAt": execution.started_at.isoformat() if execution.started_at else None,
+        "startedAt": (
+            execution.started_at.isoformat() if execution.started_at else None
+        ),
         "completedAt": (
             execution.completed_at.isoformat() if execution.completed_at else None
         ),
@@ -583,10 +588,10 @@ def build_agent_result(
             {
                 "type": "triage-results",
                 "data": {
-                    "fileCount": len(file_results)
-                    if isinstance(file_results, list)
-                    else 0,
-                    "groupings": len(groupings) if isinstance(groupings, list) else 0,
+                    "fileCount": (
+                        len(file_results) if isinstance(file_results, list) else 0
+                    ),
+                    "groupings": (len(groupings) if isinstance(groupings, list) else 0),
                 },
             }
         ]
@@ -597,9 +602,9 @@ def build_agent_result(
             {
                 "type": "routing-decisions",
                 "data": {
-                    "routingCount": len(decisions)
-                    if isinstance(decisions, list)
-                    else 0,
+                    "routingCount": (
+                        len(decisions) if isinstance(decisions, list) else 0
+                    ),
                     "parallelAgents": output.get("parallel_agents", []),
                     "researchTriggered": (output.get("research_trigger") or {}).get(
                         "should_trigger", False
@@ -627,6 +632,8 @@ def build_agent_result(
                             "targetAgent": agent,
                             "reason": rd.get("reasoning", ""),
                             "domainScore": score,
+                            "priority": rd.get("priority", "medium"),
+                            "routingConfidence": rd.get("routing_confidence"),
                         }
                     )
             result["routingDecisions"] = routing_decisions_camel
@@ -637,7 +644,9 @@ def build_agent_result(
             {
                 "type": "strategy-findings",
                 "data": {
-                    "findingCount": len(findings) if isinstance(findings, list) else 0,
+                    "findingCount": (
+                        len(findings) if isinstance(findings, list) else 0
+                    ),
                 },
             }
         ]
@@ -665,8 +674,10 @@ def build_agent_result(
             {
                 "type": f"{agent_name}-findings",
                 "data": {
-                    "findingCount": len(findings) if isinstance(findings, list) else 0,
-                    "entityCount": len(entities) if isinstance(entities, list) else 0,
+                    "findingCount": (
+                        len(findings) if isinstance(findings, list) else 0
+                    ),
+                    "entityCount": (len(entities) if isinstance(entities, list) else 0),
                     "groupLabel": group_label,
                 },
             }

backend/app/services/pipeline.py

@@ -60,7 +60,8 @@ async def _ensure_case_not_stuck(
             current = result.scalar_one_or_none()
             if current == CaseStatus.PROCESSING:
                 logger.warning(
-                    "Safety net: forcing case %s from PROCESSING to ERROR", case_id
+                    "Safety net: forcing case %s from PROCESSING to ERROR",
+                    case_id,
                 )
                 await db.execute(
                     update(Case)
@@ -312,7 +313,7 @@ async def run_analysis_workflow(
                 triage_output=triage_output,
                 db_session=db,
                 publish_event=publish_fn,
-                parent_execution_id=triage_execution.id if triage_execution else None,
+                parent_execution_id=(triage_execution.id if triage_execution else None),
             )
 
             orch_execution: AgentExecution | None = None
@@ -370,6 +371,8 @@ async def run_analysis_workflow(
                                 "targetAgent": agent,
                                 "reason": rd.reasoning,
                                 "domainScore": getattr(rd.domain_scores, agent, 0),
+                                "priority": rd.priority,
+                                "routingConfidence": rd.routing_confidence,
                             }
                             for rd in orchestrator_output.routing_decisions
                             for agent in rd.target_agents
@@ -458,7 +461,10 @@ async def run_analysis_workflow(
                             threshold = settings.get_routing_hitl_threshold(agent_type)
                             if rd.routing_confidence < threshold:
                                 item_id = str(uuid4())
-                                item_mapping[item_id] = (rd.file_id, agent_type)
+                                item_mapping[item_id] = (
+                                    rd.file_id,
+                                    agent_type,
+                                )
                                 batch_items.append(
                                     BatchConfirmationItem(
                                         item_id=item_id,
@@ -563,9 +569,9 @@ async def run_analysis_workflow(
                     hypotheses=[],  # Empty until hypothesis system exists (Phase 7)
                     db_session_factory=session_factory,
                     publish_event=publish_fn,
-                    orchestrator_execution_id=orch_execution.id
-                    if orch_execution
-                    else None,
+                    orchestrator_execution_id=(
+                        orch_execution.id if orch_execution else None
+                    ),
                 )
 
                 # Emit agent-complete/error for each agent instance
@@ -774,7 +780,7 @@ async def run_analysis_workflow(
                     hypotheses=[],
                     db_session=db,
                     publish_event=publish_fn,
-                    parent_execution_id=orch_execution.id if orch_execution else None,
+                    parent_execution_id=(orch_execution.id if orch_execution else None),
                     context_injection=strategy_context_injection,
                 )
 

frontend/src/types/command-center.ts

@@ -33,6 +33,10 @@ export interface RoutingDecision {
   targetAgent: AgentType;
   reason: string;
   domainScore: number; // Confidence score 0-100 (percentage)
+  /** Routing priority assigned by the orchestrator. */
+  priority?: "high" | "medium" | "low";
+  /** Overall routing confidence (0-100). Low values may trigger HITL review. */
+  routingConfidence?: number | null;
 }
 
 export interface AgentResult {