Function buildAgenticStepPrompt

server/handler_analysis.go:612–845

(req *pb.AgenticStepRequest)

}

func buildAgenticStepPrompt(req *pb.AgenticStepRequest) string {
	var sb strings.Builder

	sb.WriteString(fmt.Sprintf(`You are a Kubernetes SRE agent. You are autonomously remediating an active incident by executing actions one at a time. After each action, you observe the result and decide the next step.

Incident Details:
- Issue: %s
- Namespace: %s
- Resource: %s/%s
- Signal Type: %s
- Severity: %s
- Description: %s
- Risk Score: %d/100`,
		req.IssueName, req.Namespace, req.ResourceKind, req.ResourceName,
		req.SignalType, req.Severity, req.Description, req.RiskScore))

	// GAP-01 fix: inject AIInsight's prior conclusion as PRIMARY guidance, so the
	// agentic loop cannot silently contradict its own root-cause analysis. The
	// chaos test (2026-05-23) showed the loop ignoring "scale to 0" insights and
	// proposing diagnostics that got blocked by the allowlist, wasting attempts.
	if req.InsightAnalysis != "" || len(req.InsightSuggestedActions) > 0 {
		sb.WriteString("\n\nPRIMARY GUIDANCE FROM PRIOR AIInsight ANALYSIS")
		sb.WriteString(" (authoritative — follow unless new live evidence directly contradicts it):")
		if req.InsightConfidence > 0 {
			sb.WriteString(fmt.Sprintf("\n- Confidence: %.2f", req.InsightConfidence))
		}
		if req.InsightAnalysis != "" {
			sb.WriteString(fmt.Sprintf("\n- Root-cause analysis:\n<DATA>\n%s\n</DATA>", sanitizeForPrompt(req.InsightAnalysis)))
		}
		if len(req.InsightRecommendations) > 0 {
			sb.WriteString("\n- Recommendations:")
			for _, rec := range req.InsightRecommendations {
				sb.WriteString(fmt.Sprintf("\n  - %s", sanitizeForPrompt(rec)))
			}
		}
		if len(req.InsightSuggestedActions) > 0 {
			sb.WriteString("\n- Suggested actions (in priority order):")
			for i, a := range req.InsightSuggestedActions {
				sb.WriteString(fmt.Sprintf("\n  %d. %s", i+1, sanitizeForPrompt(a.Action)))
				if a.Description != "" {
					sb.WriteString(fmt.Sprintf(" — %s", sanitizeForPrompt(a.Description)))
				}
				if len(a.Params) > 0 {
					sb.WriteString(fmt.Sprintf(" %v", a.Params))
				}
			}
			sb.WriteString("\n\nIf your next_action deviates from the first suggested action above, you MUST populate `divergence_reason` in the response with a concrete justification (new evidence that invalidates the prior analysis). An empty divergence_reason while diverging will cause the operator to reject the action.")
		}
	}

	if req.KubernetesContext != "" {
		sb.WriteString(fmt.Sprintf(`

Current Kubernetes Cluster State (LIVE — refreshed before each step):
%s`, req.KubernetesContext))
	}

	sb.WriteString(`