FIX mcp unit test, missed upstream commit

Signed-off-by: Jet Chiang <pokyuen.jetchiang-ext@solo.io>

Author: supreme-gg-gg

go/core/internal/mcp/mcp_handler.go

@@ -12,10 +12,12 @@ import (
 	a2atype "github.com/a2aproject/a2a-go/v2/a2a"
 	a2aclientv2 "github.com/a2aproject/a2a-go/v2/a2aclient"
 	"github.com/a2aproject/a2a-go/v2/a2aclient/agentcard"
+	"github.com/google/jsonschema-go/jsonschema"
 	"github.com/kagent-dev/kagent/go/api/v1alpha2"
 	"github.com/kagent-dev/kagent/go/core/internal/a2a"
 	"github.com/kagent-dev/kagent/go/core/internal/version"
 	"github.com/kagent-dev/kagent/go/core/pkg/auth"
+	"github.com/kagent-dev/kagent/go/core/pkg/env"
 	mcpsdk "github.com/modelcontextprotocol/go-sdk/mcp"
 	"k8s.io/apimachinery/pkg/types"
 	"sigs.k8s.io/controller-runtime/pkg/client"
@@ -82,12 +84,21 @@ func NewMCPHandler(kubeClient client.Client, a2aBaseURL string, authenticator au
 	server := mcpsdk.NewServer(impl, nil)
 	handler.server = server
 
-	// Add list_agents tool
+	// Add list_agents tool.
+	// InputSchema is set explicitly (rather than reflected from the empty
+	// ListAgentsInput struct) so the serialized schema includes "properties": {}.
+	// OpenAI strict mode rejects object schemas without a properties key.
+	// See https://github.com/kagent-dev/kagent/issues/1889.
 	mcpsdk.AddTool[ListAgentsInput, ListAgentsOutput](
 		server,
 		&mcpsdk.Tool{
 			Name:        "list_agents",
 			Description: "List invokable kagent agents (accepted + deploymentReady)",
+			InputSchema: &jsonschema.Schema{
+				Type:                 "object",
+				Properties:           map[string]*jsonschema.Schema{},
+				AdditionalProperties: &jsonschema.Schema{Not: &jsonschema.Schema{}},
+			},
 		},
 		handler.handleListAgents,
 	)
@@ -103,11 +114,15 @@ func NewMCPHandler(kubeClient client.Client, a2aBaseURL string, authenticator au
 	)
 
 	// Create HTTP handler
+	var httpOpts *mcpsdk.StreamableHTTPOptions
+	if env.KagentMCPStateless.Get() {
+		httpOpts = &mcpsdk.StreamableHTTPOptions{Stateless: true}
+	}
 	handler.httpHandler = mcpsdk.NewStreamableHTTPHandler(
 		func(*http.Request) *mcpsdk.Server {
 			return server
 		},
-		nil,
+		httpOpts,
 	)
 
 	return handler, nil

go/core/pkg/env/kagent.go

@@ -23,6 +23,16 @@ var (
 		ComponentController,
 	)
 
+	KagentMCPStateless = RegisterBoolVar(
+		"KAGENT_MCP_STATELESS",
+		false,
+		"When true, the MCP server operates in stateless mode (no session persistence). "+
+			"Use when the network path does not provide sticky session routing based on the Mcp-Session-Id header. "+
+			"Note: stateless mode disables server-initiated notifications; clients will not receive "+
+			"resources/updated events.",
+		ComponentController,
+	)
+
 	// Variables injected into agent pods (not read by the controller itself).
 
 	KagentName = RegisterStringVar(