-h^ lSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SS KJ r SS K J r SS K J r SS K J r SS KJr \ R""SS05r\ R""SS05r\ R("\ SSSS//SQ/SQS9"SS\55r"SS5r"SS\\5rSrSr\\lg) N)engine)result)ReversibleProxy)StartableContext)_ensure_sync_result)util)object_session)Session)state)greenlet_spawnprebuffer_rowsTstream_resultsz:class:`_orm.Session`z:class:`_asyncio.AsyncSession`r identity_key) __contains____iter__addadd_allexpire expire_allexpunge expunge_all is_modifiedin_transactionin_nested_transaction)dirtydeletednew identity_map is_active autoflush no_autoflushinfo) classmethodsmethods attributesc\rSrSr%SrSrSrS!Sjr\r \\ S'S"Sjr Sr S\ RS4S jrS\ RS4S jrS\ RS4S jrS#S jrS\ RS4S jrS\ RS4SjrSrS$SjrS%SjrSrSrS!SjrSrSrSrSrSrSr Sr!\"S5r#Sr$Sr%Sr&S r'g)& AsyncSessionaIAsyncio version of :class:`_orm.Session`. The :class:`_asyncio.AsyncSession` is a proxy for a traditional :class:`_orm.Session` instance. .. versionadded:: 1.4 To use an :class:`_asyncio.AsyncSession` with custom :class:`_orm.Session` implementations, see the :paramref:`_asyncio.AsyncSession.sync_session_class` parameter. TNc dSUS'U(aXl[R"U5nU(a?X lUR 5VVs0sHupVU[R"U5_M nnnU(aX0lUR UR "SXS.UD65=UlUlgs snnf)a}Construct a new :class:`_asyncio.AsyncSession`. All parameters other than ``sync_session_class`` are passed to the ``sync_session_class`` callable directly to instantiate a new :class:`_orm.Session`. Refer to :meth:`_orm.Session.__init__` for parameter documentation. :param sync_session_class: A :class:`_orm.Session` subclass or other callable which will be used to construct the :class:`_orm.Session` which will be proxied. This parameter may be used to provide custom :class:`_orm.Session` subclasses. Defaults to the :attr:`_asyncio.AsyncSession.sync_session_class` class-level attribute. .. versionadded:: 1.4.24 Tfuture)bindbindsN) r-r_get_sync_engine_or_connectionr.itemssync_session_class_assign_proxied sync_session_proxied)selfr-r.r2kwkeybs sC:\Users\ROHAN GUPTA\OneDrive\Desktop\mathbuddy-assessment\venv\Lib\site-packages\sqlalchemy/ext/asyncio/session.py__init__AsyncSession.__init__Hs&8 I88>D J$kkm+FCV::1==+  &8 #,0,@,@  # # A Ab A-  DMs #B,r4c^# [URRUUUS9IShvN $N7f)a}Expire and refresh the attributes on the given instance. A query will be issued to the database and all attributes will be refreshed with their current database value. This is the async version of the :meth:`_orm.Session.refresh` method. See that method for a complete description of all options. .. seealso:: :meth:`_orm.Session.refresh` - main documentation for refresh )attribute_nameswith_for_updateN)rr4refresh)r6instancer>r?s r:r@AsyncSession.refreshs6"$    % % ++     $-+-cP# [XR/UQ70UD6IShvN $N7f)aInvoke the given sync callable passing sync self as the first argument. This method maintains the asyncio event loop all the way through to the database connection by running the given callable in a specially instrumented greenlet. E.g.:: with AsyncSession(async_engine) as session: await session.run_sync(some_business_method) .. note:: The provided callable is invoked inline within the asyncio event loop, and will block on traditional IO calls. IO within this callable should only call into SQLAlchemy's asyncio database APIs which will be properly adapted to the greenlet context. .. seealso:: :ref:`session_run_sync` N)rr4)r6fnargr7s r:run_syncAsyncSession.run_syncs(2$B(9(9FCF2FFFFs &$&c# U(a*[R"U5R[5nO[n[ UR R U4UUUS.UD6IShvN n[X`R 5IShvN $N!N7f)zExecute a statement and return a buffered :class:`_engine.Result` object. .. seealso:: :meth:`_orm.Session.execute` - main documentation for execute paramsexecution_optionsbind_argumentsN)r immutabledictunion_EXECUTE_OPTIONSrr4executerr6 statementrKrLrMr7rs r:rQAsyncSession.executes"  $ 2 23D E K K ! !1 %    % %  /)     )>>> ?s$A B"B#B?BBBcl# UR"U4UUUS.UD6IShvN nUR5$N7f)zExecute a statement and return a scalar result. .. seealso:: :meth:`_orm.Session.scalar` - main documentation for scalar rJN)rQscalarrRs r:rVAsyncSession.scalarsH ||  /)     }} 424cl# UR"U4UUUS.UD6IShvN nUR5$N7f)aExecute a statement and return scalar results. :return: a :class:`_result.ScalarResult` object .. versionadded:: 1.4.24 Added :meth:`_asyncio.AsyncSession.scalars` .. versionadded:: 1.4.26 Added :meth:`_asyncio.async_scoped_session.scalars` .. seealso:: :meth:`_orm.Session.scalars` - main documentation for scalars :meth:`_asyncio.AsyncSession.stream_scalars` - streaming version rJN)rQscalarsrRs r:rZAsyncSession.scalarssI2||  /)     ~~ rXc d# [URRUUUUUUS9IShvN $N7f)zReturn an instance based on the given primary key identifier, or ``None`` if not found. .. seealso:: :meth:`_orm.Session.get` - main documentation for get )optionspopulate_existingr?identity_tokenN)rr4get)r6entityidentr]r^r?r_s r:r`AsyncSession.gets?$$    ! !  /+)    s '0.0c# U(a*[R"U5R[5nO[n[ UR R U4UUUS.UD6IShvN n[R"U5$N7f)zRExecute a statement and return a streaming :class:`_asyncio.AsyncResult` object. rJN) r rNrO_STREAM_OPTIONSrr4rQ_result AsyncResultrRs r:streamAsyncSession.stream7s  $ 2 23D E K K! !0 %    % %  /)     ""6** sA A?"A=#A?cl# UR"U4UUUS.UD6IShvN nUR5$N7f)a"Execute a statement and return a stream of scalar results. :return: an :class:`_asyncio.AsyncScalarResult` object .. versionadded:: 1.4.24 .. seealso:: :meth:`_orm.Session.scalars` - main documentation for scalars :meth:`_asyncio.AsyncSession.scalars` - non streaming version rJN)rhrZrRs r:stream_scalarsAsyncSession.stream_scalarsUsI,{{  /)     ~~ rXc^# [URRU5IShvN $N7f)a$Mark an instance as deleted. The database delete operation occurs upon ``flush()``. As this operation may need to cascade along unloaded relationships, it is awaitable to allow for those queries to take place. .. seealso:: :meth:`_orm.Session.delete` - main documentation for delete N)rr4delete)r6rAs r:rnAsyncSession.deletets&$D$5$5$<$$>????rtc\# [URR5IShvN $N7f)z+Commit the current transaction in progress.N)rr4commitrs r:rAsyncSession.commitGs"#D$5$5$<$<====rtc^# [URR5IShvN gN7f)aClose out the transactional resources and ORM objects used by this :class:`_asyncio.AsyncSession`. This expunges all ORM objects associated with this :class:`_asyncio.AsyncSession`, ends any transaction in progress and :term:`releases` any :class:`_asyncio.AsyncConnection` objects which this :class:`_asyncio.AsyncSession` itself has checked out from associated :class:`_asyncio.AsyncEngine` objects. The operation then leaves the :class:`_asyncio.AsyncSession` in a state which it may be used again. .. tip:: The :meth:`_asyncio.AsyncSession.close` method **does not prevent the Session from being used again**. The :class:`_asyncio.AsyncSession` itself does not actually have a distinct "closed" state; it merely means the :class:`_asyncio.AsyncSession` will release all database connections and ORM objects. .. seealso:: :ref:`session_closing` - detail on the semantics of :meth:`_asyncio.AsyncSession.close` N)rr4closers r:rAsyncSession.closeKs!8T..44555s #-+-c\# [URR5IShvN $N7f)zuClose this Session, using connection invalidation. For a complete description, see :meth:`_orm.Session.invalidate`. N)rr4 invalidaters r:rAsyncSession.invalidateis$ $D$5$5$@$@AAAArtc\# [URR5IShvN $N7f)z2Close all :class:`_asyncio.AsyncSession` sessions.N)rr4 close_allrs r:rAsyncSession.close_allps$$D$5$5$?$?@@@@rtc# U$7fNr/rs r: __aenter__AsyncSession.__aenter__us  sc# [R"5RUR55n[R"U5IShvN gN7fr)asyncioget_event_loop create_taskrshield)r6type_value tracebacktasks r: __aexit__AsyncSession.__aexit__xs6%%'33DJJLAnnT"""sA AAAc[U5$r)_AsyncSessionContextManagerrs r:_maker_context_manager#AsyncSession._maker_context_manager|s *400r)r5r-r.r4r2)NNN)NN)NFNN)TNr)(__name__ __module__ __qualname____firstlineno____doc__ _is_asynciodispatchr;r r2__annotations__r@rGr EMPTY_DICTrQrVrZr`rhrkrnrrrwrzrrrrrrrrr classmethodrrrr__static_attributes__r/rr:r)r)s*< KH$ L!  ?C 0G<// ?J// 8//  L >// +B//  > H  G  L \ 0-. :@>6<BAA#1rr)c&\rSrSrSrSrSrSrg)ricXlgr) async_session)r6rs r:r;$_AsyncSessionContextManager.__init__s*rc# URR5UlURR5IShvN UR$N7fr)rrr~rrs r:r&_AsyncSessionContextManager.__aenter__sB''--/ jj##%%%!!! &s=AAAc^^^^# UUUU4Sjn[R"5RU"55n[R"U5IShvN gN7f)Nc># TRRTTT5IShvN TRRTTT5IShvN gN*N7fr)r~rr)r6rrrsr:go1_AsyncSessionContextManager.__aexit__..gosI**&&ueY? ? ?$$..ueYG G G @ Gs!!AA$A A AA)rrrr)r6rrrrrs```` r:r%_AsyncSessionContextManager.__aexit__sA H H%%'33BD9nnT"""sA AAA)rr~N)rrrrr;rrrr/rr:rrs+" #rrcX\rSrSrSrSrS Sjr\S5rSr Sr Sr S S jr S r S rg )r{iaA wrapper for the ORM :class:`_orm.SessionTransaction` object. This object is provided so that a transaction-holding object for the :meth:`_asyncio.AsyncSession.begin` may be returned. The object supports both explicit calls to :meth:`_asyncio.AsyncSessionTransaction.commit` and :meth:`_asyncio.AsyncSessionTransaction.rollback`, as well as use as an async context manager. .. versionadded:: 1.4 )sessionsync_transactionrc*XlX lSUlgr)rrr)r6rrs r:r; AsyncSessionTransaction.__init__s  $rchUR5SL=(a UR5R$r)_sync_transactionr!rs r:r!!AsyncSessionTransaction.is_actives1  " " $D 0 3&&(22 rc\UR(dUR5 UR$r)r_raise_for_not_startedrs r:r)AsyncSessionTransaction._sync_transactions#$$  ' ' )$$$rcf# [UR5R5IShvN gN7f)z2Roll back this :class:`_asyncio.AsyncTransaction`.N)rrrrs r:r AsyncSessionTransaction.rollbacks"T335>>??? '1/1cf# [UR5R5IShvN gN7f)z/Commit this :class:`_asyncio.AsyncTransaction`.N)rrrrs r:rAsyncSessionTransaction.commits$T335<<===rc@# UR[UR(a URRR OURRR 5IShvN 5UlU(aURR5 U$N07fr) r3rrrr4rrr __enter__)r6 is_ctxmanagers r:startAsyncSessionTransaction.startsu $ 4 4 ;; ))66\\..44 !    ! ! + + -  sA)B+B,1Bcj# [UR5RXU5IShvN gN7fr)rr__exit__)r6rrrs r:r!AsyncSessionTransaction.__aexit__s-  " " $ - -uY   s )313)rrrN)F)rrrrr __slots__r;propertyr!rrrrrrr/rr:r{r{sA :I%   % @>  rr{c6[U5nUb [U5$g)awReturn the :class:`_asyncio.AsyncSession` to which the given instance belongs. This function makes use of the sync-API function :class:`_orm.object_session` to retrieve the :class:`_orm.Session` which refers to the given instance, and from there links it to the original :class:`_asyncio.AsyncSession`. If the :class:`_asyncio.AsyncSession` has been garbage collected, the return value is ``None``. This functionality is also available from the :attr:`_orm.InstanceState.async_session` accessor. :param instance: an ORM mapped instance :return: an :class:`_asyncio.AsyncSession` object, or ``None``. .. versionadded:: 1.4.18 N)r r)rArs r:async_object_sessionrs",X&GW%%rc*[RUSS9$)zReturn the :class:`_asyncio.AsyncSession` which is proxying the given :class:`_orm.Session` object, if any. :param session: a :class:`_orm.Session` instance. :return: a :class:`_asyncio.AsyncSession` instance, or ``None``. .. versionadded:: 1.4.18 F) regenerate)r)r|)rs r:rrs  2 27u 2 MMr)rrrrfbaserrrr ormr r r _instance_stateutil.concurrencyrrNrPrecreate_proxy_methodsr)rr{rr_async_providerr/rr:rs!"'!+.%%'7&>?$$&6%=> $"N3  %:I 1?I 1;:I 1X##$; o/?; |: N#0r