Merge pull request #646 from gargnipungarg/main

Fastmcp v2 migration

Author: SudhiMurthy

model-deployment/mcp-servers/oci-cache-redis-server/model-deplyment.py

@@ -78,7 +78,7 @@ def get_datascience_client():
             "healthCheckPort": 8000,
             "environmentVariables": {
                 "WEB_CONCURRENCY": "1",
-                "MODEL_DEPLOY_PREDICT_ENDPOINT": "/mcp/"
+                "MODEL_DEPLOY_PREDICT_ENDPOINT": "/mcp"
             }
         }
     },

model-deployment/mcp-servers/oci-cache-redis-server/pyproject.toml

@@ -9,4 +9,6 @@ dependencies = [
     "redis>=6.0.0",
     "dotenv>=0.9.9",
     "numpy>=2.2.4",
+    "fastmcp>=2.12.3",
+    "uvicorn>=0.34.0",
 ]

model-deployment/mcp-servers/oci-cache-redis-server/src/common/server.py

@@ -1,4 +1,4 @@
-from mcp.server.fastmcp import FastMCP
+from fastmcp import FastMCP
 from starlette.responses import JSONResponse
 from starlette.requests import Request
 from starlette.responses import Response
@@ -13,25 +13,14 @@
     "Redis MCP Server",
     host=MCP_HOST,
     port=MCP_PORT,
-    dependencies=["redis", "dotenv", "numpy"]
+    dependencies=["redis", "dotenv", "numpy"],
+    stateless_http=True,
+    json_response=True
 )
 
-mcp._session_manager = StreamableHTTPSessionManager(
-        app=mcp._mcp_server,
-        event_store=None,
-        json_response=True,
-        stateless=True,
-    )
-
 def handle_health(request):
         return JSONResponse({"status": "success"})
 
-async def handle_streamable_http(
-    scope: Scope, receive: Receive, send: Send
-) -> None:
-    await mcp._session_manager.handle_request(scope, receive, send)
-
-mcp._custom_starlette_routes=[
-            Mount("/mcp", app=handle_streamable_http),
-            Route('/health', endpoint=handle_health),
-        ]
+mcp._additional_http_routes = [
+    Route('/health', endpoint=handle_health),
+]

model-deployment/mcp-servers/oci-cache-redis-server/src/main.py

@@ -1,19 +1,19 @@
 import sys
 
 from common.connection import RedisConnectionManager
-from common.server import mcp
 import tools.server_management
 import tools.misc 
 import tools.redis_query_engine
 import tools.hash
-import tools.list
-import tools.string
-import tools.json
-import tools.sorted_set
-import tools.set
-import tools.stream
-import tools.pub_sub
-from common.config import MCP_TRANSPORT
+#import tools.list
+#import tools.string
+#import tools.json
+#import tools.sorted_set
+#import tools.set
+#import tools.stream
+#import tools.pub_sub
+from common.server import mcp
+from common.config import MCP_TRANSPORT, MCP_HOST, MCP_PORT
 
 
 class RedisMCPServer: