uv ruff fixes

Author: davemssavage

src/mcp/shared/session.py

@@ -447,7 +447,7 @@ async def join_request(
     ) -> ReceiveResultT | None:
         """
         Joins a request previously started via start_request.
-        
+
         Returns the result or None if timeout is reached.
         """
         resume = self._request_state_manager.resume(request_id)
@@ -483,7 +483,7 @@ async def join_request(
 
         if response_or_error is None:
             if done_on_timeout:
-                await self._request_state_manager.close_request(request_id)  
+                await self._request_state_manager.close_request(request_id)
             return None
         elif isinstance(response_or_error, JSONRPCError):
             if response_or_error.error.code == httpx.codes.REQUEST_TIMEOUT.value:
@@ -493,11 +493,10 @@ async def join_request(
             else:
                 await self._request_state_manager.close_request(request_id)
                 raise McpError(response_or_error.error)
-        else :
+        else:
             await self._request_state_manager.close_request(request_id)
             return result_type.model_validate(response_or_error.result)
 
-
     async def cancel_request(self, request_id: RequestId) -> bool:
         """
         Cancels a request previously started via start_request

tests/client/test_session.py

@@ -2,13 +2,11 @@
 from typing import Any
 
 import anyio
-import httpx
 import pytest
 
 import mcp.types as types
 from mcp.client.session import DEFAULT_CLIENT_INFO, ClientSession
 from mcp.shared.context import RequestContext
-from mcp.shared.exceptions import McpError
 from mcp.shared.message import SessionMessage
 from mcp.shared.session import InMemoryRequestStateManager, RequestResponder
 from mcp.shared.version import SUPPORTED_PROTOCOL_VERSIONS

tests/shared/test_streamable_http.py

@@ -1396,10 +1396,11 @@ async def run_tool():
                         captured_request_id = await session.request_call_tool(
                             "long_running_with_checkpoints", arguments={}
                         )
-                        
+
                         result = await session.join_call_tool(
-                            captured_request_id, request_read_timeout_seconds=timedelta(seconds=0.01),
-                            done_on_timeout=False
+                            captured_request_id,
+                            request_read_timeout_seconds=timedelta(seconds=0.01),
+                            done_on_timeout=False,
                         )
 
                         assert result is None
@@ -1474,7 +1475,7 @@ async def run_tool():
                 assert not any(n in captured_notifications_pre for n in captured_notifications), (
                     f"{captured_notifications_pre} -> {captured_notifications}"
                 )
-                
+
         assert len(request_state_manager_1._progress_callbacks) == 0
         assert len(request_state_manager_1._response_streams) == 0
         assert len(request_state_manager_2._progress_callbacks) == 0