Browse Source

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

pull/14099/head
pre-commit-ci[bot] 3 days ago
parent
commit
9087a2a1a6
  1. 22
      fastapi/routing.py

22
fastapi/routing.py

@ -83,6 +83,7 @@ if sys.version_info >= (3, 13): # pragma: no cover
else: # pragma: no cover else: # pragma: no cover
from asyncio import iscoroutinefunction from asyncio import iscoroutinefunction
# Copy of starlette.routing.request_response modified to include the # Copy of starlette.routing.request_response modified to include the
# dependencies' AsyncExitStack # dependencies' AsyncExitStack
def request_response( def request_response(
@ -117,11 +118,13 @@ def request_response(
"and is not raising the exception again. Read more about it in the " "and is not raising the exception again. Read more about it in the "
"docs: https://fastapi.tiangolo.com/tutorial/dependencies/dependencies-with-yield/#dependencies-with-yield-and-except" "docs: https://fastapi.tiangolo.com/tutorial/dependencies/dependencies-with-yield/#dependencies-with-yield-and-except"
) )
# Same as in Starlette # Same as in Starlette
await wrap_app_handling_exceptions(app, request)(scope, receive, send) await wrap_app_handling_exceptions(app, request)(scope, receive, send)
return app return app
# Copy of starlette.routing.websocket_session modified to include the # Copy of starlette.routing.websocket_session modified to include the
# dependencies' AsyncExitStack # dependencies' AsyncExitStack
def websocket_session( def websocket_session(
@ -141,6 +144,7 @@ def websocket_session(
scope["fastapi_inner_astack"] = stack scope["fastapi_inner_astack"] = stack
# Same as in Starlette # Same as in Starlette
await func(session) await func(session)
# Same as in Starlette # Same as in Starlette
await wrap_app_handling_exceptions(app, session)(scope, receive, send) await wrap_app_handling_exceptions(app, session)(scope, receive, send)
@ -312,9 +316,9 @@ def get_request_handler(
async def app(request: Request) -> Response: async def app(request: Request) -> Response:
response: Union[Response, None] = None response: Union[Response, None] = None
file_stack = request.scope.get("fastapi_middleware_astack") file_stack = request.scope.get("fastapi_middleware_astack")
assert isinstance( assert isinstance(file_stack, AsyncExitStack), (
file_stack, AsyncExitStack "fastapi_astack not found in request scope"
), "fastapi_astack not found in request scope" )
# Read body and auto-close files # Read body and auto-close files
try: try:
@ -367,9 +371,9 @@ def get_request_handler(
# Solve dependencies and run path operation function, auto-closing dependencies # Solve dependencies and run path operation function, auto-closing dependencies
errors: List[Any] = [] errors: List[Any] = []
async_exit_stack = request.scope.get("fastapi_inner_astack") async_exit_stack = request.scope.get("fastapi_inner_astack")
assert isinstance( assert isinstance(async_exit_stack, AsyncExitStack), (
async_exit_stack, AsyncExitStack "fastapi_inner_astack not found in request scope"
), "fastapi_inner_astack not found in request scope" )
solved_result = await solve_dependencies( solved_result = await solve_dependencies(
request=request, request=request,
dependant=dependant, dependant=dependant,
@ -437,9 +441,9 @@ def get_websocket_app(
) -> Callable[[WebSocket], Coroutine[Any, Any, Any]]: ) -> Callable[[WebSocket], Coroutine[Any, Any, Any]]:
async def app(websocket: WebSocket) -> None: async def app(websocket: WebSocket) -> None:
async_exit_stack = websocket.scope.get("fastapi_inner_astack") async_exit_stack = websocket.scope.get("fastapi_inner_astack")
assert isinstance( assert isinstance(async_exit_stack, AsyncExitStack), (
async_exit_stack, AsyncExitStack "fastapi_inner_astack not found in request scope"
), "fastapi_inner_astack not found in request scope" )
solved_result = await solve_dependencies( solved_result = await solve_dependencies(
request=websocket, request=websocket,
dependant=dependant, dependant=dependant,

Loading…
Cancel
Save