Remove blocking behavior workaround in MCP ClientSession

mcp_bridge/mcp_clients/session.py

@@ -40,31 +40,6 @@ def __init__(
             read_timeout_seconds=read_timeout_seconds,
         )
 
-    async def __aenter__(self):
-        session = await super().__aenter__()
-        self._task_group.start_soon(self._consume_messages)
-        return session
-
-    async def _consume_messages(self):
-        try:
-            async for message in self.incoming_messages:
-                try:
-                    if isinstance(message, Exception):
-                        logger.error(f"Received exception in message stream: {message}")
-                    elif isinstance(message, RequestResponder):                        
-                        logger.debug(f"Received request: {message.request}")                        
-                    elif isinstance(message, types.ServerNotification):
-                        if isinstance(message.root, types.LoggingMessageNotification):
-                            logger.debug(f"Received notification from server: {message.root.params}")                        
-                        else:
-                            logger.debug(f"Received notification from server: {message}")                        
-                    else:
-                        logger.debug(f"Received notification: {message}")
-                except Exception as e:
-                    logger.exception(f"Error processing message: {e}")
-        except Exception as e:
-            logger.exception(f"Message consumer task failed: {e}")
-
     async def initialize(self) -> types.InitializeResult:
         result = await self.send_request(
             types.ClientRequest(

pyproject.toml

@@ -11,7 +11,7 @@ dependencies = [
     "httpx-sse>=0.4.0",
     "lmos-openai-types",
     "loguru>=0.7.3",
-    "mcp>=1.2.0,<=1.7.1",
+    "mcp>=1.6.0,<=1.7.1",
     "mcpx[docker]>=0.1.1",
     "opentelemetry-api>=1.33.1",
     "opentelemetry-exporter-otlp>=1.33.1",