U cc @sddlmZddlmZddlmZddlmZeedddd d gd d d ddddddddddddddddddd d!d"d#d$d%gd&d'd(d)d*d+d,d-d.g d/Gd0d1d1eZd2S)3) AsyncSession)ScopedSessionMixin)create_proxy_methods)ScopedRegistryz:class:`_asyncio.AsyncSession`z.:class:`_asyncio.scoping.async_scoped_session`Z close_allZobject_sessionZ identity_key __contains____iter__addZadd_allbeginZ begin_nestedclosecommit connectiondeleteexecuteZexpireZ expire_allZexpungeZ expunge_allflushgetZget_bindZ is_modifiedZ invalidatemergeZrefreshrollbackZscalarZscalarsstreamZstream_scalarsbindZdirtyZdeletednewZ identity_mapZ is_activeZ autoflushZ no_autoflushinfo)Z classmethodsmethods attributesc@s0eZdZdZdZddZeddZddZd S) async_scoped_sessionzProvides scoped management of :class:`.AsyncSession` objects. See the section :ref:`asyncio_scoped_session` for usage details. .. versionadded:: 1.4.19 TcCs||_t|||_dS)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)selfrZ scopefuncrB/tmp/pip-unpacked-wheel-8u86ls_i/sqlalchemy/ext/asyncio/scoping.py__init__Hszasync_scoped_session.__init__cCs|S)N)rrrrr_proxied]szasync_scoped_session._proxiedcs*|jr|IdH|jdS)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)rZhasr clearr!rrrremoveas zasync_scoped_session.removeN) __name__ __module__ __qualname____doc__Z_support_asyncr propertyr"r$rrrrrs /  rN)sessionrZ orm.scopingrutilrrrrrrrs`    .