🎨 [pre-commit.ci] Auto format from pre-commit.com hooks

fastapi/concurrency.py

@@ -1,8 +1,9 @@
-from contextlib import asynccontextmanager as asynccontextmanager
-from typing import AsyncGenerator, ContextManager, TypeVar, Optional
 import functools
 import sys
 import typing
+from contextlib import asynccontextmanager as asynccontextmanager
+from typing import AsyncGenerator, ContextManager, Optional, TypeVar
+
 if sys.version_info >= (3, 10):  # pragma: no cover
     from typing import ParamSpec
 else:  # pragma: no cover
@@ -18,20 +19,23 @@ from starlette.concurrency import (  # noqa
 _P = ParamSpec("_P")
 _T = TypeVar("_T")
 
+
 async def run_in_threadpool(
     func: typing.Callable[_P, _T],
     *args: typing.Any,
     _limiter: Optional[anyio.CapacityLimiter] = None,
-    **kwargs: typing.Any
+    **kwargs: typing.Any,
 ) -> _T:
     if kwargs:  # pragma: no cover
         # run_sync doesn't accept 'kwargs', so bind them in here
         func = functools.partial(func, **kwargs)
     return await anyio.to_thread.run_sync(func, *args, limiter=_limiter)
 
+
 @asynccontextmanager
 async def contextmanager_in_threadpool(
-    cm: ContextManager[_T], limiter: Optional[anyio.CapacityLimiter] = None,
+    cm: ContextManager[_T],
+    limiter: Optional[anyio.CapacityLimiter] = None,
 ) -> AsyncGenerator[_T, None]:
     # blocking __exit__ from running waiting on a free thread
     # can create race conditions/deadlocks if the context manager itself
@@ -51,6 +55,4 @@ async def contextmanager_in_threadpool(
         if not ok:
             raise e
     else:
-        await run_in_threadpool(
-            cm.__exit__, None, None, None, _limiter=exit_limiter
-        )
+        await run_in_threadpool(cm.__exit__, None, None, None, _limiter=exit_limiter)

fastapi/dependencies/models.py

@@ -1,7 +1,7 @@
 from dataclasses import dataclass, field
 from typing import Any, Callable, List, Optional, Sequence, Tuple
-import anyio
 
+import anyio
 from fastapi._compat import ModelField
 from fastapi.security.base import SecurityBase
 

fastapi/dependencies/utils.py

@@ -533,12 +533,16 @@ def is_gen_callable(call: Callable[..., Any]) -> bool:
 
 
 async def solve_generator(
-    *, call: Callable[..., Any], stack: AsyncExitStack, sub_values: Dict[str, Any],
+    *,
+    call: Callable[..., Any],
+    stack: AsyncExitStack,
+    sub_values: Dict[str, Any],
     limiter: Optional[anyio.CapacityLimiter] = None,
 ) -> Any:
     if is_gen_callable(call):
-        cm = contextmanager_in_threadpool(contextmanager(call)(**sub_values),
-                                          limiter=limiter)
+        cm = contextmanager_in_threadpool(
+            contextmanager(call)(**sub_values), limiter=limiter
+        )
     elif is_async_gen_callable(call):
         cm = asynccontextmanager(call)(**sub_values)
     return await stack.enter_async_context(cm)
@@ -615,14 +619,17 @@ async def solve_dependencies(
             solved = dependency_cache[sub_dependant.cache_key]
         elif is_gen_callable(call) or is_async_gen_callable(call):
             solved = await solve_generator(
-                call=call, stack=async_exit_stack, sub_values=solved_result.values,
+                call=call,
+                stack=async_exit_stack,
+                sub_values=solved_result.values,
                 limiter=sub_dependant.limiter,
             )
         elif is_coroutine_callable(call):
             solved = await call(**solved_result.values)
         else:
-            solved = await run_in_threadpool(call, _limiter=sub_dependant.limiter,
-                                             **solved_result.values)
+            solved = await run_in_threadpool(
+                call, _limiter=sub_dependant.limiter, **solved_result.values
+            )
         if sub_dependant.name is not None:
             values[sub_dependant.name] = solved
         if sub_dependant.cache_key not in dependency_cache:

fastapi/param_functions.py

@@ -1,6 +1,6 @@
 from typing import Any, Callable, Dict, List, Optional, Sequence, Union
-import anyio
 
+import anyio
 from fastapi import params
 from fastapi._compat import Undefined
 from fastapi.openapi.models import Example
@@ -2384,5 +2384,6 @@ def Security(  # noqa: N802
         return [{"item_id": "Foo", "owner": current_user.username}]
     ```
     """
-    return params.Security(dependency=dependency, scopes=scopes, use_cache=use_cache,
-                           limiter=limiter)
+    return params.Security(
+        dependency=dependency, scopes=scopes, use_cache=use_cache, limiter=limiter
+    )

fastapi/params.py

@@ -1,8 +1,8 @@
 import warnings
 from enum import Enum
 from typing import Any, Callable, Dict, List, Optional, Sequence, Union
-import anyio
 
+import anyio
 from fastapi.openapi.models import Example
 from pydantic.fields import FieldInfo
 from typing_extensions import Annotated, deprecated
@@ -761,7 +761,9 @@ class File(Form):
 
 class Depends:
     def __init__(
-        self, dependency: Optional[Callable[..., Any]] = None, *,
+        self,
+        dependency: Optional[Callable[..., Any]] = None,
+        *,
         use_cache: bool = True,
         limiter: Optional[anyio.CapacityLimiter] = None,
     ):
@@ -772,8 +774,11 @@ class Depends:
     def __repr__(self) -> str:
         attr = getattr(self.dependency, "__name__", type(self.dependency).__name__)
         cache = "" if self.use_cache else ", use_cache=False"
-        limiter = f", limiter=CapacityLimiter({self.limiter.total_tokens})" \
-            if self.limiter else ""
+        limiter = (
+            f", limiter=CapacityLimiter({self.limiter.total_tokens})"
+            if self.limiter
+            else ""
+        )
         return f"{self.__class__.__name__}({attr}{cache}{limiter})"