Fixed pre-commit errors

Author: agronholm

src/mcp/client/streamable_http.py

@@ -442,9 +442,7 @@ async def streamablehttp_client(
 
         async with create_mcp_http_client(
             headers=transport.request_headers,
-            timeout=httpx.Timeout(
-                transport.timeout, read=transport.sse_read_timeout
-            ),
+            timeout=httpx.Timeout(transport.timeout, read=transport.sse_read_timeout),
         ) as client:
             async with anyio.create_task_group() as tg:
                 # Define callbacks that need access to tg

src/mcp/server/session.py

@@ -97,12 +97,10 @@ def __init__(
 
     async def __aenter__(self) -> Self:
         await super().__aenter__()
-        self._incoming_message_stream_writer, self._incoming_message_stream_reader = (
-            anyio.create_memory_object_stream[ServerRequestResponder](0)
-        )
-        self._exit_stack.push_async_callback(
-            self._incoming_message_stream_reader.aclose
-        )
+        self._incoming_message_stream_writer, self._incoming_message_stream_reader = anyio.create_memory_object_stream[
+            ServerRequestResponder
+        ](0)
+        self._exit_stack.push_async_callback(self._incoming_message_stream_reader.aclose)
         return self
 
     @property

src/mcp/shared/session.py

@@ -202,9 +202,7 @@ def __init__(
 
     async def __aenter__(self) -> Self:
         async with AsyncExitStack() as exit_stack:
-            self._task_group = await exit_stack.enter_async_context(
-                anyio.create_task_group()
-            )
+            self._task_group = await exit_stack.enter_async_context(anyio.create_task_group())
             self._task_group.start_soon(self._receive_loop)
             # Using BaseSession as a context manager should not block on exit (this
             # would be very surprising behavior), so make sure to cancel the tasks