ruff format

starlette/authentication.py

@@ -35,7 +35,7 @@ def requires(
     scopes_list = [scopes] if isinstance(scopes, str) else list(scopes)
 
     def decorator(
-        func: typing.Callable[_P, typing.Any]
+        func: typing.Callable[_P, typing.Any],
     ) -> typing.Callable[_P, typing.Any]:
         sig = inspect.signature(func)
         for idx, parameter in enumerate(sig.parameters.values()):

starlette/routing.py

@@ -55,7 +55,9 @@ def iscoroutinefunction_or_partial(obj: typing.Any) -> bool:  # pragma: no cover
 
 
 def request_response(
-    func: typing.Callable[[Request], typing.Union[typing.Awaitable[Response], Response]]
+    func: typing.Callable[
+        [Request], typing.Union[typing.Awaitable[Response], Response]
+    ],
 ) -> ASGIApp:
     """
     Takes a function or coroutine `func(request) -> response`,
@@ -78,7 +80,7 @@ async def app(scope: Scope, receive: Receive, send: Send) -> None:
 
 
 def websocket_session(
-    func: typing.Callable[[WebSocket], typing.Awaitable[None]]
+    func: typing.Callable[[WebSocket], typing.Awaitable[None]],
 ) -> ASGIApp:
     """
     Takes a coroutine `func(session)`, and returns an ASGI application.

starlette/types.py

@@ -26,7 +26,5 @@
 HTTPExceptionHandler = typing.Callable[
     ["Request", E], typing.Union["Response", typing.Awaitable["Response"]]
 ]
-WebSocketExceptionHandler = typing.Callable[
-    ["WebSocket", E], typing.Awaitable[None]
-]
+WebSocketExceptionHandler = typing.Callable[["WebSocket", E], typing.Awaitable[None]]
 ExceptionHandler = typing.Union[HTTPExceptionHandler[E], WebSocketExceptionHandler[E]]

tests/middleware/test_base.py

@@ -499,7 +499,7 @@ async def downstream_app(scope, receive, send):
 
 
 def test_read_request_stream_in_app_after_middleware_calls_stream(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         expected = [b""]
@@ -527,7 +527,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_stream_in_app_after_middleware_calls_body(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         expected = [b"a", b""]
@@ -552,7 +552,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_body_in_app_after_middleware_calls_stream(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         assert await request.body() == b""
@@ -577,7 +577,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_body_in_app_after_middleware_calls_body(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         assert await request.body() == b"a"
@@ -599,7 +599,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_stream_in_dispatch_after_app_calls_stream(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         expected = [b"a", b""]
@@ -627,7 +627,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_stream_in_dispatch_after_app_calls_body(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         assert await request.body() == b"a"
@@ -705,7 +705,7 @@ async def send(msg: Message) -> None:
 
 
 def test_read_request_stream_in_dispatch_after_app_calls_body_with_middleware_calling_body_before_call_next(  # noqa: E501
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         assert await request.body() == b"a"
@@ -733,7 +733,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint):
 
 
 def test_read_request_body_in_dispatch_after_app_calls_body_with_middleware_calling_body_before_call_next(  # noqa: E501
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     async def homepage(request: Request):
         assert await request.body() == b"a"
@@ -837,7 +837,7 @@ async def send(msg: Message):
 
 
 def test_downstream_middleware_modifies_receive(
-    test_client_factory: Callable[[ASGIApp], TestClient]
+    test_client_factory: Callable[[ASGIApp], TestClient],
 ) -> None:
     """If a downstream middleware modifies receive() the final ASGI app
     should see the modified version.

tests/test_background.py

@@ -69,7 +69,7 @@ async def app(scope, receive, send):
 
 
 def test_multi_tasks_failure_avoids_next_execution(
-    test_client_factory: Callable[..., TestClient]
+    test_client_factory: Callable[..., TestClient],
 ) -> None:
     TASK_COUNTER = 0
 

tests/test_routing.py

@@ -1110,7 +1110,7 @@ async def modified_send(msg: Message) -> None:
 
 
 def test_websocket_route_middleware(
-    test_client_factory: typing.Callable[..., TestClient]
+    test_client_factory: typing.Callable[..., TestClient],
 ):
     async def websocket_endpoint(session: WebSocket):
         await session.accept()

tests/test_websockets.py

@@ -40,7 +40,7 @@ async def app(scope: Scope, receive: Receive, send: Send) -> None:
 
 
 def test_websocket_ensure_unicode_on_send_json(
-    test_client_factory: Callable[..., TestClient]
+    test_client_factory: Callable[..., TestClient],
 ):
     async def app(scope: Scope, receive: Receive, send: Send) -> None:
         websocket = WebSocket(scope, receive=receive, send=send)