run precommit

Author: bjoaquinc

src/mcp/server/streaming_asgi_transport.py

@@ -176,7 +176,6 @@ async def process_messages() -> None:
                 response_complete.set()
                 await content_send_channel.aclose()
 
-
         # Create tasks for running the app and processing messages
         self.task_group.start_soon(run_app)
         self.task_group.start_soon(process_messages)

tests/shared/test_sse.py

@@ -368,12 +368,13 @@ def context_server(server_port: int) -> Generator[None, None, None]:
     if proc.is_alive():
         print("context server process failed to terminate")
 
+
 @pytest.fixture()
 async def context_app() -> Starlette:
     """Fixture that provides the context server app"""
     security_settings = TransportSecuritySettings(
-        allowed_hosts=["127.0.0.1:*", "localhost:*", "testserver"], 
-        allowed_origins=["http://127.0.0.1:*", "http://localhost:*", "http://testserver"]
+        allowed_hosts=["127.0.0.1:*", "localhost:*", "testserver"],
+        allowed_origins=["http://127.0.0.1:*", "http://localhost:*", "http://testserver"],
     )
     sse = SseServerTransport("/messages/", security_settings=security_settings)
     context_server = RequestContextServer()
@@ -403,6 +404,7 @@ async def test_request_context_propagation(context_app: Starlette) -> None:
     }
 
     async with anyio.create_task_group() as tg:
+
         def create_test_client(
             headers: dict[str, str] | None = None,
             timeout: httpx.Timeout | None = None,
@@ -418,10 +420,12 @@ def create_test_client(
                 follow_redirects=True,
             )
 
-        async with sse_client("http://testserver/sse", 
-        headers=custom_headers, 
-        httpx_client_factory=create_test_client,
-        sse_read_timeout=0.5) as (
+        async with sse_client(
+            "http://testserver/sse",
+            headers=custom_headers,
+            httpx_client_factory=create_test_client,
+            sse_read_timeout=0.5,
+        ) as (
             read_stream,
             write_stream,
         ):