style: format code with ruff

Author: max-rousseau

src/mcp/server/streamable_http_manager.py

@@ -173,9 +173,7 @@ async def _handle_stateless_request(
         )
 
         # Start server in a new task
-        async def run_stateless_server(
-            *, task_status: TaskStatus[None] = anyio.TASK_STATUS_IGNORED
-        ):
+        async def run_stateless_server(*, task_status: TaskStatus[None] = anyio.TASK_STATUS_IGNORED):
             async with http_transport.connect() as streams:
                 read_stream, write_stream = streams
                 task_status.started()
@@ -218,10 +216,7 @@ async def _handle_stateful_request(
         request_mcp_session_id = request.headers.get(MCP_SESSION_ID_HEADER)
 
         # Existing session case
-        if (
-            request_mcp_session_id is not None
-            and request_mcp_session_id in self._server_instances
-        ):  # pragma: no cover
+        if request_mcp_session_id is not None and request_mcp_session_id in self._server_instances:  # pragma: no cover
             transport = self._server_instances[request_mcp_session_id]
             logger.debug("Session already exists, handling request directly")
             await transport.handle_request(scope, receive, send)
@@ -245,9 +240,7 @@ async def _handle_stateful_request(
                 logger.info(f"Created new transport with session ID: {new_session_id}")
 
                 # Define the server runner
-                async def run_server(
-                    *, task_status: TaskStatus[None] = anyio.TASK_STATUS_IGNORED
-                ) -> None:
+                async def run_server(*, task_status: TaskStatus[None] = anyio.TASK_STATUS_IGNORED) -> None:
                     async with http_transport.connect() as streams:
                         read_stream, write_stream = streams
                         task_status.started()
@@ -267,18 +260,15 @@ async def run_server(
                             # Only remove from instances if not terminated
                             if (  # pragma: no branch
                                 http_transport.mcp_session_id
-                                and http_transport.mcp_session_id
-                                in self._server_instances
+                                and http_transport.mcp_session_id in self._server_instances
                                 and not http_transport.is_terminated
                             ):
                                 logger.info(
                                     "Cleaning up crashed session "
                                     f"{http_transport.mcp_session_id} from "
                                     "active instances."
                                 )
-                                del self._server_instances[
-                                    http_transport.mcp_session_id
-                                ]
+                                del self._server_instances[http_transport.mcp_session_id]
 
                 # Assert task group is not None for type checking
                 assert self._task_group is not None