style: Apply ruff formatting fixes

Auto-formatted by pre-commit ruff-format hook:
- 5 files reformatted
- 221 files left unchanged

This resolves the pre-commit formatting check.

Author: spacelord16

src/mcp/client/stdio/__init__.py

@@ -124,11 +124,7 @@ async def stdio_client(server: StdioServerParameters, errlog: TextIO = sys.stder
         process = await _create_platform_compatible_process(
             command=command,
             args=server.args,
-            env=(
-                {**get_default_environment(), **server.env}
-                if server.env is not None
-                else get_default_environment()
-            ),
+            env=({**get_default_environment(), **server.env} if server.env is not None else get_default_environment()),
             errlog=errlog,
             cwd=server.cwd,
         )
@@ -172,9 +168,7 @@ async def stdin_writer():
         try:
             async with write_stream_reader:
                 async for session_message in write_stream_reader:
-                    json = session_message.message.model_dump_json(
-                        by_alias=True, exclude_none=True
-                    )
+                    json = session_message.message.model_dump_json(by_alias=True, exclude_none=True)
                     await process.stdin.send(
                         (json + "\n").encode(
                             encoding=server.encoding,
@@ -260,9 +254,7 @@ async def _create_platform_compatible_process(
     return process
 
 
-async def _terminate_process_tree(
-    process: Process | FallbackProcess, timeout_seconds: float | None = None
-) -> None:
+async def _terminate_process_tree(process: Process | FallbackProcess, timeout_seconds: float | None = None) -> None:
     """
     Terminate a process and all its children using platform-specific methods.
 

tests/client/test_stdio.py

@@ -32,9 +32,7 @@
 
 
 @pytest.mark.anyio
-@pytest.mark.skip(
-    "Skip context manager timing test - process termination varies by platform"
-)
+@pytest.mark.skip("Skip context manager timing test - process termination varies by platform")
 async def test_stdio_context_manager_exiting():
     async with stdio_client(StdioServerParameters(command=tee)) as (_, _):
         pass
@@ -68,20 +66,14 @@ async def test_stdio_client():
                     break
 
         assert len(read_messages) == 2
-        assert read_messages[0] == JSONRPCMessage(
-            root=JSONRPCRequest(jsonrpc="2.0", id=1, method="ping")
-        )
-        assert read_messages[1] == JSONRPCMessage(
-            root=JSONRPCResponse(jsonrpc="2.0", id=2, result={})
-        )
+        assert read_messages[0] == JSONRPCMessage(root=JSONRPCRequest(jsonrpc="2.0", id=1, method="ping"))
+        assert read_messages[1] == JSONRPCMessage(root=JSONRPCResponse(jsonrpc="2.0", id=2, result={}))
 
 
 @pytest.mark.anyio
 async def test_stdio_client_bad_path():
     """Check that the connection doesn't hang if process errors."""
-    server_params = StdioServerParameters(
-        command="python", args=["-c", "non-existent-file.py"]
-    )
+    server_params = StdioServerParameters(command="python", args=["-c", "non-existent-file.py"])
     async with stdio_client(server_params) as (read_stream, write_stream):
         async with ClientSession(read_stream, write_stream) as session:
             # The session should raise an error when the connection closes
@@ -267,9 +259,7 @@ class TestChildProcessCleanup:
     """
 
     @pytest.mark.anyio
-    @pytest.mark.filterwarnings(
-        "ignore::ResourceWarning" if sys.platform == "win32" else "default"
-    )
+    @pytest.mark.filterwarnings("ignore::ResourceWarning" if sys.platform == "win32" else "default")
     async def test_basic_child_process_cleanup(self):
         """
         Test basic parent-child process cleanup.
@@ -318,9 +308,7 @@ async def test_basic_child_process_cleanup(self):
             print("\nStarting child process termination test...")
 
             # Start the parent process
-            proc = await _create_platform_compatible_process(
-                sys.executable, ["-c", parent_script]
-            )
+            proc = await _create_platform_compatible_process(sys.executable, ["-c", parent_script])
 
             # Wait for processes to start
             await anyio.sleep(0.5)
@@ -334,9 +322,7 @@ async def test_basic_child_process_cleanup(self):
                 await anyio.sleep(0.3)
                 size_after_wait = os.path.getsize(marker_file)
                 assert size_after_wait > initial_size, "Child process should be writing"
-                print(
-                    f"Child is writing (file grew from {initial_size} to {size_after_wait} bytes)"
-                )
+                print(f"Child is writing (file grew from {initial_size} to {size_after_wait} bytes)")
 
             # Terminate using our function
             print("Terminating process and children...")
@@ -352,9 +338,9 @@ async def test_basic_child_process_cleanup(self):
                 final_size = os.path.getsize(marker_file)
 
                 print(f"After cleanup: file size {size_after_cleanup} -> {final_size}")
-                assert (
-                    final_size == size_after_cleanup
-                ), f"Child process still running! File grew by {final_size - size_after_cleanup} bytes"
+                assert final_size == size_after_cleanup, (
+                    f"Child process still running! File grew by {final_size - size_after_cleanup} bytes"
+                )
 
             print("SUCCESS: Child process was properly terminated")
 
@@ -367,9 +353,7 @@ async def test_basic_child_process_cleanup(self):
                     pass
 
     @pytest.mark.anyio
-    @pytest.mark.filterwarnings(
-        "ignore::ResourceWarning" if sys.platform == "win32" else "default"
-    )
+    @pytest.mark.filterwarnings("ignore::ResourceWarning" if sys.platform == "win32" else "default")
     async def test_nested_process_tree(self):
         """
         Test nested process tree cleanup (parent → child → grandchild).
@@ -429,9 +413,7 @@ async def test_nested_process_tree(self):
             )
 
             # Start the parent process
-            proc = await _create_platform_compatible_process(
-                sys.executable, ["-c", parent_script]
-            )
+            proc = await _create_platform_compatible_process(sys.executable, ["-c", parent_script])
 
             # Let all processes start
             await anyio.sleep(1.0)
@@ -477,9 +459,7 @@ async def test_nested_process_tree(self):
                     pass
 
     @pytest.mark.anyio
-    @pytest.mark.filterwarnings(
-        "ignore::ResourceWarning" if sys.platform == "win32" else "default"
-    )
+    @pytest.mark.filterwarnings("ignore::ResourceWarning" if sys.platform == "win32" else "default")
     async def test_early_parent_exit(self):
         """
         Test cleanup when parent exits during termination sequence.
@@ -523,9 +503,7 @@ def handle_term(sig, frame):
             )
 
             # Start the parent process
-            proc = await _create_platform_compatible_process(
-                sys.executable, ["-c", parent_script]
-            )
+            proc = await _create_platform_compatible_process(sys.executable, ["-c", parent_script])
 
             # Let child start writing
             await anyio.sleep(0.5)
@@ -561,9 +539,7 @@ def handle_term(sig, frame):
 
 
 @pytest.mark.anyio
-@pytest.mark.skip(
-    "Skip graceful exit timing test - process termination varies by platform"
-)
+@pytest.mark.skip("Skip graceful exit timing test - process termination varies by platform")
 async def test_stdio_client_graceful_stdin_exit():
     """
     Test that a process exits gracefully when stdin is closed,
@@ -620,9 +596,7 @@ async def test_stdio_client_graceful_stdin_exit():
 
 
 @pytest.mark.anyio
-@pytest.mark.skip(
-    "Skip stdin close timing test - process termination varies by platform"
-)
+@pytest.mark.skip("Skip stdin close timing test - process termination varies by platform")
 async def test_stdio_client_stdin_close_ignored():
     """
     Test that when a process ignores stdin closure, the shutdown sequence

tests/server/fastmcp/test_integration.py

@@ -80,9 +80,7 @@ def run_server_with_transport(module_name: str, port: int, transport: str) -> No
     import sys
 
     # Add examples/snippets to Python path for multiprocessing context
-    snippets_path = os.path.join(
-        os.path.dirname(__file__), "..", "..", "..", "examples", "snippets"
-    )
+    snippets_path = os.path.join(os.path.dirname(__file__), "..", "..", "..", "examples", "snippets")
     sys.path.insert(0, os.path.abspath(snippets_path))
 
     # Import the servers module in the multiprocessing context
@@ -131,9 +129,7 @@ def run_server_with_transport(module_name: str, port: int, transport: str) -> No
     else:
         raise ValueError(f"Invalid transport for test server: {transport}")
 
-    server = uvicorn.Server(
-        config=uvicorn.Config(app=app, host="127.0.0.1", port=port, log_level="error")
-    )
+    server = uvicorn.Server(config=uvicorn.Config(app=app, host="127.0.0.1", port=port, log_level="error"))
     print(f"Starting {transport} server on port {port}")
     server.run()
 
@@ -173,9 +169,7 @@ def server_transport(request, server_port: int) -> Generator[str, None, None]:
             time.sleep(delay)
             attempt += 1
     else:
-        raise RuntimeError(
-            f"Server failed to start after {max_attempts} attempts (port {server_port})"
-        )
+        raise RuntimeError(f"Server failed to start after {max_attempts} attempts (port {server_port})")
 
     yield transport
 
@@ -352,14 +346,10 @@ async def test_basic_prompts(server_transport: str, server_url: str) -> None:
 
             # Test review_code prompt
             prompts = await session.list_prompts()
-            review_prompt = next(
-                (p for p in prompts.prompts if p.name == "review_code"), None
-            )
+            review_prompt = next((p for p in prompts.prompts if p.name == "review_code"), None)
             assert review_prompt is not None
 
-            prompt_result = await session.get_prompt(
-                "review_code", {"code": "def hello():\n    print('Hello')"}
-            )
+            prompt_result = await session.get_prompt("review_code", {"code": "def hello():\n    print('Hello')"})
             assert isinstance(prompt_result, GetPromptResult)
             assert len(prompt_result.messages) == 1
             assert isinstance(prompt_result.messages[0].content, TextContent)
@@ -415,18 +405,16 @@ async def test_tool_progress(server_transport: str, server_url: str) -> None:
             assert result.capabilities.tools is not None
 
             # Test long_running_task tool that reports progress
-            tool_result = await session.call_tool(
-                "long_running_task", {"task_name": "test", "steps": 3}
-            )
+            tool_result = await session.call_tool("long_running_task", {"task_name": "test", "steps": 3})
             assert len(tool_result.content) == 1
             assert isinstance(tool_result.content[0], TextContent)
             assert "Task 'test' completed" in tool_result.content[0].text
 
             # Verify that progress notifications or log messages were sent
             # Progress can come through either progress notifications or log messages
-            total_notifications = len(
-                notification_collector.progress_notifications
-            ) + len(notification_collector.log_messages)
+            total_notifications = len(notification_collector.progress_notifications) + len(
+                notification_collector.log_messages
+            )
             assert total_notifications > 0
 
 
@@ -447,9 +435,7 @@ async def test_sampling(server_transport: str, server_url: str) -> None:
 
     async with client_cm as client_streams:
         read_stream, write_stream = unpack_streams(client_streams)
-        async with ClientSession(
-            read_stream, write_stream, sampling_callback=sampling_callback
-        ) as session:
+        async with ClientSession(read_stream, write_stream, sampling_callback=sampling_callback) as session:
             # Test initialization
             result = await session.initialize()
             assert isinstance(result, InitializeResult)
@@ -480,9 +466,7 @@ async def test_elicitation(server_transport: str, server_url: str) -> None:
 
     async with client_cm as client_streams:
         read_stream, write_stream = unpack_streams(client_streams)
-        async with ClientSession(
-            read_stream, write_stream, elicitation_callback=elicitation_callback
-        ) as session:
+        async with ClientSession(read_stream, write_stream, elicitation_callback=elicitation_callback) as session:
             # Test initialization
             result = await session.initialize()
             assert isinstance(result, InitializeResult)
@@ -528,9 +512,7 @@ async def test_completion(server_transport: str, server_url: str) -> None:
             assert len(prompts.prompts) > 0
 
             # Test getting a prompt
-            prompt_result = await session.get_prompt(
-                "review_code", {"language": "python", "code": "def test(): pass"}
-            )
+            prompt_result = await session.get_prompt("review_code", {"language": "python", "code": "def test(): pass"})
             assert len(prompt_result.messages) > 0
 
 
@@ -642,9 +624,7 @@ async def test_structured_output(server_transport: str, server_url: str) -> None
             assert result.serverInfo.name == "Structured Output Example"
 
             # Test get_weather tool
-            weather_result = await session.call_tool(
-                "get_weather", {"city": "New York"}
-            )
+            weather_result = await session.call_tool("get_weather", {"city": "New York"})
             assert len(weather_result.content) == 1
             assert isinstance(weather_result.content[0], TextContent)