o
ADi
@ s d dl mZ d dlZd dlZd dlmZ d dlmZmZ d dl Z d dl
m Z m Z m
Z
d dlZd dlmZ e jG dd dZdd
dZeeje ef ZdS ) ) annotationsN)AsyncGenerator) AnnotatedCallable)DependsFastAPIRequest)
_KEY_REGISTRYc @ sT e Zd ZU dZded< ejedZded< eje j
dZ ded< e j
dd
dZdS )lifespanat
Make a FastAPI lifespan *svcs*-aware.
Makes sure that the registry is available to the decorated lifespan
function as a second parameter and that the registry is closed when the
application exists.
Async generators are automatically wrapped into an async context manager.
Args:
lifespan: The lifespan function to make *svcs*-aware.
a? Callable[[FastAPI, svcs.Registry], contextlib.AbstractAsyncContextManager[dict[str, object]]] | Callable[[FastAPI, svcs.Registry], contextlib.AbstractAsyncContextManager[None]] | Callable[[FastAPI, svcs.Registry], AsyncGenerator[dict[str, object], None]] | Callable[[FastAPI, svcs.Registry], AsyncGenerator[None, None]] _lifespan)factoryzdict[str, object]_statez
svcs.Registryregistryappr return'AsyncGenerator[dict[str, object], None]c
C s t | jrt| j}n| j}| j4 I d H ; ||| j4 I d H }|p'i | _| j| jt< | jV W d I d H n 1 I d H sCw Y W d I d H d S 1 I d H sYw Y d S )N)inspectisasyncgenfunctionr
contextlibasynccontextmanagerr r
r )selfr cmstate r E/var/www/Datamplify/venv/lib/python3.10/site-packages/svcs/fastapi.py__call__6 s &
Xzlifespan.__call__N)r r r r )__name__
__module__ __qualname____doc____annotations__attrsfielddictr
svcsRegistryr r r r r r r r r
s
r
requestr r $AsyncGenerator[svcs.Container, None]c C sT t t| jt4 I dH }|V W d I dH dS 1 I dH s#w Y dS )z
A FastAPI `dependency
`_ that provides you
with a request-scoped container.
Yields:
A :class:`svcs.Container` that is cleaned up after the request.
N)r$ Containergetattrr r )r& contr r r containerH s .r+ )r& r r r' )
__future__r r r collections.abcr typingr r r! fastapir r r r$
svcs._corer definer
r+ r( DepContainerr r r r s
1