+h xddlmZddlmZddlmZddlmZeeddgdgd gd  Gd d eZy)) AsyncSession)ScopedSessionMixin)create_proxy_methods)ScopedRegistryz:class:`_asyncio.AsyncSession`z.:class:`_asyncio.scoping.async_scoped_session`) close_allobject_session identity_key) __contains____iter__addadd_allbegin begin_nestedclosecommit connectiondeleteexecuteexpire expire_allexpunge expunge_allflushgetget_bind is_modified invalidatemergerefreshrollbackscalarscalarsstreamstream_scalars) binddirtydeletednew identity_map is_active autoflush no_autoflushinfo) classmethodsmethods attributesc0eZdZdZdZdZedZdZy)async_scoped_sessionzProvides scoped management of :class:`.AsyncSession` objects. See the section :ref:`asyncio_scoped_session` for usage details. .. versionadded:: 1.4.19 Tc4||_t|||_y)aConstruct a new :class:`_asyncio.async_scoped_session`. :param session_factory: a factory to create new :class:`_asyncio.AsyncSession` instances. This is usually, but not necessarily, an instance of :class:`_orm.sessionmaker` which itself was passed the :class:`_asyncio.AsyncSession` to its :paramref:`_orm.sessionmaker.class_` parameter:: async_session_factory = sessionmaker(some_async_engine, class_= AsyncSession) AsyncSession = async_scoped_session(async_session_factory, scopefunc=current_task) :param scopefunc: function which defines the current scope. A function such as ``asyncio.current_task`` may be useful here. N)session_factoryrregistry)selfr5 scopefuncs Q/var/www/html/venv/lib/python3.12/site-packages/sqlalchemy/ext/asyncio/scoping.py__init__zasync_scoped_session.__init__Hs$ /& B c"|jS)N)r6r7s r9_proxiedzasync_scoped_session._proxied]s}}r;cK|jjr&|jjd{|jjy7w)zDispose of the current :class:`.AsyncSession`, if present. Different from scoped_session's remove method, this method would use await to wait for the close method of AsyncSession. N)r6hasrclearr=s r9removezasync_scoped_session.removeasE ==   --/'') ) )  *srBr;r9r3r3s.^NC* r;r3N)sessionr orm.scopingrutilrrr3rIr;r9rMsN"-("$4@ : E-\/-/]-\/r;