formatting

Author: crondinini-ant

src/mcp/client/sse.py

@@ -93,9 +93,7 @@ async def sse_reader(
                                             raise ValueError(error_msg)  # pragma: no cover
 
                                         if on_session_created:
-                                            session_id = parse_qs(endpoint_parsed.query).get(
-                                                "sessionId", [None]
-                                            )[0]
+                                            session_id = parse_qs(endpoint_parsed.query).get("sessionId", [None])[0]
                                             if session_id:
                                                 on_session_created(session_id)
 

tests/shared/test_sse.py

@@ -192,9 +192,7 @@ def on_session_created(session_id: str) -> None:
         nonlocal captured_session_id
         captured_session_id = session_id
 
-    async with sse_client(
-        server_url + "/sse", on_session_created=on_session_created
-    ) as streams:
+    async with sse_client(server_url + "/sse", on_session_created=on_session_created) as streams:
         async with ClientSession(*streams) as session:
             result = await session.initialize()
             assert isinstance(result, InitializeResult)