fmt

Author: akash329d

src/mcp/client/sse.py

@@ -152,4 +152,3 @@ async def post_writer(endpoint_url: str):
             await write_stream.aclose()
             await read_stream.aclose()
             await write_stream_reader.aclose()
-            

tests/server/message_dispatch/test_redis.py

@@ -104,9 +104,11 @@ async def test_publish_message_invalid_json(message_dispatch):
 async def test_publish_to_nonexistent_session(message_dispatch: RedisMessageDispatch):
     """Test publishing to a session that doesn't exist."""
     session_id = uuid4()
-    message = SessionMessage(message=types.JSONRPCMessage.model_validate(
-        {"jsonrpc": "2.0", "method": "test", "params": {}, "id": 1}
-    ))
+    message = SessionMessage(
+        message=types.JSONRPCMessage.model_validate(
+            {"jsonrpc": "2.0", "method": "test", "params": {}, "id": 1}
+        )
+    )
 
     published = await message_dispatch.publish_message(session_id, message)
     assert not published

tests/server/message_dispatch/test_redis_integration.py

@@ -148,7 +148,9 @@ async def server_and_redis(redis_server_and_app, server_port: int):
                     await anyio.sleep(0.1)
                     attempt += 1
             else:
-                raise RuntimeError(f"Server failed to start after {max_attempts} attempts")
+                raise RuntimeError(
+                    f"Server failed to start after {max_attempts} attempts"
+                )
 
             # Yield Redis for tests
             try: