updates from ruff format

Author: davemssavage

src/mcp/client/session.py

@@ -140,7 +140,7 @@ async def initialize(self) -> types.InitializeResult:
                 )
             ),
             types.InitializeResult,
-            cancellable=False
+            cancellable=False,
         )
 
         if result.protocolVersion not in SUPPORTED_PROTOCOL_VERSIONS:

src/mcp/server/lowlevel/server.py

@@ -448,15 +448,13 @@ def decorator(
             logger.debug("Registering handler for CancelledNotification")
 
             async def handler(req: types.CancelledNotification):
-                await func(
-                    req.params.requestId, req.params.reason
-                )
+                await func(req.params.requestId, req.params.reason)
 
             self.notification_handlers[types.CancelledNotification] = handler
             return func
 
         return decorator
-    
+
     def completion(self):
         """Provides completions for prompts and resource templates"""
 

src/mcp/shared/session.py

@@ -35,8 +35,10 @@
 SendResultT = TypeVar("SendResultT", ClientResult, ServerResult)
 SendNotificationT = TypeVar("SendNotificationT", ClientNotification, ServerNotification)
 SendNotificationInternalT = TypeVar(
-    "SendNotificationInternalT", 
-    CancelledNotification, ClientNotification, ServerNotification
+    "SendNotificationInternalT",
+    CancelledNotification,
+    ClientNotification,
+    ServerNotification,
 )
 ReceiveRequestT = TypeVar("ReceiveRequestT", ClientRequest, ServerRequest)
 ReceiveResultT = TypeVar("ReceiveResultT", bound=BaseModel)
@@ -269,14 +271,13 @@ async def send_request(
                             notification = CancelledNotification(
                                 method="notifications/cancelled",
                                 params=CancelledNotificationParams(
-                                    requestId=request_id, 
-                                    reason="cancelled"
-                                )
+                                    requestId=request_id, reason="cancelled"
+                                ),
                             )
                             await self._send_notification_internal(
                                 notification, request_id
                             )
-                            
+
                         raise McpError(
                             ErrorData(code=32601, message="Request cancelled")
                         )
@@ -292,7 +293,7 @@ async def send_request(
                         ),
                     )
                 )
-            
+
             if isinstance(response_or_error, JSONRPCError):
                 raise McpError(response_or_error.error)
             else:

tests/shared/test_session.py

@@ -62,7 +62,7 @@ async def handle_call_tool(name: str, arguments: dict | None) -> list:
                 await anyio.sleep(10)  # Long enough to ensure we can cancel
                 return []
             raise ValueError(f"Unknown tool: {name}")
-        
+
         @server.cancel_notification()
         async def handle_cancel(requestId: str | int, reason: str | None):
             nonlocal ev_cancel_notified