Function processMCPFailureEntry

pkg/cli/logs_metrics.go:764–806

(entry map[string]any, run WorkflowRun, verbose bool, experimentName, variant string, mcpFailures *[]MCPFailureReport)

}

func processMCPFailureEntry(entry map[string]any, run WorkflowRun, verbose bool, experimentName, variant string, mcpFailures *[]MCPFailureReport) {
	entryType, ok := typeutil.LookupString(entry, "type")
	if !ok || entryType != "system" {
		return
	}

	subtype, ok := typeutil.LookupString(entry, "subtype")
	if !ok || subtype != "init" {
		return
	}

	mcpServers, ok := entry["mcp_servers"].([]any)
	if !ok {
		return
	}

	timestamp, _ := typeutil.LookupString(entry, "timestamp") // Optional field, ignore if missing.

	for _, serverInterface := range mcpServers {
		server, ok := serverInterface.(map[string]any)
		if !ok {
			continue
		}

		serverName, hasName := typeutil.LookupString(server, "name")
		status, hasStatus := typeutil.LookupString(server, "status")
		if !hasName || !hasStatus || status != "failed" {
			continue
		}

		failure := MCPFailureReport{
			ServerName:       serverName,
			Status:           status,
			ReportProvenance: buildReportProvenance(run, timestamp, experimentName, variant),
		}

		*mcpFailures = append(*mcpFailures, failure)

		if verbose {
			fmt.Fprintln(os.Stderr, console.FormatWarningMessage(fmt.Sprintf("Found MCP server failure: %s (status: %s)", serverName, status)))
		}
	}
}