coverage: run ruff on long lines

Author: maxisbey

src/mcp/server/fastmcp/server.py

@@ -1225,7 +1225,9 @@ async def log(
     @property
     def client_id(self) -> str | None:
         """Get the client ID if available."""
-        return getattr(self.request_context.meta, "client_id", None) if self.request_context.meta else None  # pragma: no cover
+        return (
+            getattr(self.request_context.meta, "client_id", None) if self.request_context.meta else None
+        )  # pragma: no cover
 
     @property
     def request_id(self) -> str:

src/mcp/server/fastmcp/utilities/func_metadata.py

@@ -477,7 +477,9 @@ class DictModel(RootModel[dict_annotation]):
 
 
 def _get_typed_annotation(annotation: Any, globalns: dict[str, Any]) -> Any:
-    def try_eval_type(value: Any, globalns: dict[str, Any], localns: dict[str, Any]) -> tuple[Any, bool]:  # pragma: no cover
+    def try_eval_type(
+        value: Any, globalns: dict[str, Any], localns: dict[str, Any]
+    ) -> tuple[Any, bool]:  # pragma: no cover
         try:
             return eval_type_backport(value, globalns, localns), True
         except NameError:

src/mcp/server/lowlevel/server.py

@@ -679,7 +679,9 @@ async def _handle_request(
             try:
                 # Extract request context from message metadata
                 request_data = None
-                if message.message_metadata is not None and isinstance(message.message_metadata, ServerMessageMetadata):  # pragma: no cover
+                if message.message_metadata is not None and isinstance(
+                    message.message_metadata, ServerMessageMetadata
+                ):  # pragma: no cover
                     request_data = message.message_metadata.request_context
 
                 # Set our global state that can be retrieved via

src/mcp/server/streamable_http.py

@@ -369,7 +369,9 @@ async def _handle_post_request(self, scope: Scope, request: Request, receive: Re
                 return
 
             # Check if this is an initialization request
-            is_initialization_request = isinstance(message.root, JSONRPCRequest) and message.root.method == "initialize" # pragma: no cover
+            is_initialization_request = (
+                isinstance(message.root, JSONRPCRequest) and message.root.method == "initialize"
+            )  # pragma: no cover
 
             if is_initialization_request: # pragma: no cover
                 # Check if the server already has an established session

src/mcp/shared/session.py

@@ -46,7 +46,9 @@
 class ProgressFnT(Protocol):
     """Protocol for progress notification callbacks."""
 
-    async def __call__(self, progress: float, total: float | None, message: str | None) -> None: ...  # pragma: no branch
+    async def __call__(
+        self, progress: float, total: float | None, message: str | None
+    ) -> None: ...  # pragma: no branch
 
 
 class RequestResponder(Generic[ReceiveRequestT, SendResultT]):

tests/client/test_resource_cleanup.py

@@ -19,7 +19,9 @@ async def test_send_request_stream_cleanup():
 
     # Create a mock session with the minimal required functionality
     class TestSession(BaseSession[ClientRequest, ClientNotification, ClientResult, Any, Any]):
-        async def _send_response(self, request_id: RequestId, response: SendResultT | ErrorData) -> None:  # pragma: no cover
+        async def _send_response(
+            self, request_id: RequestId, response: SendResultT | ErrorData
+        ) -> None:  # pragma: no cover
             pass
 
     # Create streams

tests/server/fastmcp/test_elicitation.py

@@ -71,7 +71,9 @@ async def test_stdio_elicitation():
     create_ask_user_tool(mcp)
 
     # Create a custom handler for elicitation requests
-    async def elicitation_callback(context: RequestContext[ClientSession, None], params: ElicitRequestParams):  # pragma: no cover
+    async def elicitation_callback(
+        context: RequestContext[ClientSession, None], params: ElicitRequestParams
+    ):  # pragma: no cover
         if params.message == "Tool wants to ask: What is your name?":
             return ElicitResult(action="accept", content={"answer": "Test User"})
         else:
@@ -126,7 +128,9 @@ class InvalidNestedSchema(BaseModel):
     create_validation_tool("nested_model", InvalidNestedSchema)
 
     # Dummy callback (won't be called due to validation failure)
-    async def elicitation_callback(context: RequestContext[ClientSession, None], params: ElicitRequestParams):  # pragma: no cover
+    async def elicitation_callback(
+        context: RequestContext[ClientSession, None], params: ElicitRequestParams
+    ):  # pragma: no cover
         return ElicitResult(action="accept", content={})
 
     async with create_connected_server_and_client_session(
@@ -203,7 +207,9 @@ async def invalid_optional_tool(ctx: Context[ServerSession, None]) -> str:  # pr
         except TypeError as e:
             return f"Validation failed: {str(e)}"
 
-    async def elicitation_callback(context: RequestContext[ClientSession, None], params: ElicitRequestParams):  # pragma: no cover
+    async def elicitation_callback(
+        context: RequestContext[ClientSession, None], params: ElicitRequestParams
+    ):  # pragma: no cover
         return ElicitResult(action="accept", content={})
 
     await call_tool_and_assert(

tests/server/fastmcp/test_tool_manager.py

@@ -347,7 +347,9 @@ def tool_without_context(x: int) -> str:  # pragma: no cover
         tool = manager.add_tool(tool_without_context)
         assert tool.context_kwarg is None
 
-        def tool_with_parametrized_context(x: int, ctx: Context[ServerSessionT, LifespanContextT, RequestT]) -> str:  # pragma: no cover
+        def tool_with_parametrized_context(
+            x: int, ctx: Context[ServerSessionT, LifespanContextT, RequestT]
+        ) -> str:  # pragma: no cover
             return str(x)
 
         tool = manager.add_tool(tool_with_parametrized_context)

tests/server/test_session.py

@@ -58,7 +58,9 @@ async def run_server():
                 if isinstance(message, Exception):  # pragma: no cover
                     raise message
 
-                if isinstance(message, ClientNotification) and isinstance(message.root, InitializedNotification):  # pragma: no branch
+                if isinstance(message, ClientNotification) and isinstance(
+                    message.root, InitializedNotification
+                ):  # pragma: no branch
                     received_initialized = True
                     return
 
@@ -154,7 +156,9 @@ async def run_server():
                 if isinstance(message, Exception):  # pragma: no cover
                     raise message
 
-                if isinstance(message, types.ClientNotification) and isinstance(message.root, InitializedNotification):  # pragma: no branch
+                if isinstance(message, types.ClientNotification) and isinstance(
+                    message.root, InitializedNotification
+                ):  # pragma: no branch
                     received_initialized = True
                     return
 
@@ -239,7 +243,9 @@ async def run_server():
                     raise message
 
                 # We should receive a ping request before initialization
-                if isinstance(message, RequestResponder) and isinstance(message.request.root, types.PingRequest):  # pragma: no branch
+                if isinstance(message, RequestResponder) and isinstance(
+                    message.request.root, types.PingRequest
+                ):  # pragma: no branch
                     # Respond to the ping
                     with message:
                         await message.respond(types.ServerResult(types.EmptyResult()))

tests/shared/test_progress_notifications.py

@@ -335,7 +335,9 @@ def mock_log_error(msg: str, *args: Any) -> None:
         logged_errors.append(msg % args if args else msg)
 
     # Create a progress callback that raises an exception
-    async def failing_progress_callback(progress: float, total: float | None, message: str | None) -> None:  # pragma: no cover
+    async def failing_progress_callback(
+        progress: float, total: float | None, message: str | None
+    ) -> None:  # pragma: no cover
         raise ValueError("Progress callback failed!")
 
     # Create a server with a tool that sends progress notifications