more

Author: anakin87

integrations/mcp/src/haystack_integrations/tools/mcp/mcp_tool.py

@@ -560,10 +560,10 @@ async def connect(self) -> list[types.Tool]:
         elif self.token:
             headers = {"Authorization": f"Bearer {self.token}"}
 
-        streamable_http_transport = await self.exit_stack.enter_async_context(
+        streamablehttp_transport = await self.exit_stack.enter_async_context(
             streamablehttp_client(url=self.url, headers=headers, timeout=timedelta(seconds=self.timeout))
         )
-        return await self._initialize_session_with_transport(streamable_http_transport, f"HTTP server at {self.url}")
+        return await self._initialize_session_with_transport(streamablehttp_transport, f"HTTP server at {self.url}")
 
 
 @dataclass