ޠj SSKJr SSKrSSKJrJr SSKrSSKrSSKrSSK r SSK J r SSK J r JrJr SSKrSSKJr SSKJr SS KJr SS KJr \R,"\5r"S S \5r"S S\R6\SS9r"SS5r"SS5r"SS5rSSSSSSSSSS\R@\RBS. Sjjr"g)) annotationsN) AwaitableCallable) TracebackType)AnyOptionalType)compat connection) exceptions)protocolcf^\rSrSrSS.SU4Sjjjr\SSj5rSrU=r$) PoolConnectionProxyMetaF)wrapc>U(a[[R5HnURS5(dXS;aM [ [RU5n[ R "U5(dMW[ R"U5nURXW5n[R"X5nXU'M SU;a[RRUS'[T U]5XX#5$)N___doc__)dirr Connection startswithgetattrinspect isfunctioniscoroutinefunction_wrap_connection_method functoolsupdate_wrapperrsuper__new__) mclsnamebasesdctrattrnamemeth iscoroutinewrapper __class__s F/var/www/html/gaurav/venv/lib/python3.13/site-packages/asyncpg/pool.pyr"PoolConnectionProxyMeta.__new__s  5 56&&s++xz44h?))$//%99$? 66xM#227A 'H 7#!+!6!6!>!>Iwt566cR^SU4SjjnU(a[R"U5 U$)Nc>URc%[R"SRT55e[ URR T5nU"UR/UQ70UD6$)NzJcannot call Connection.{}(): connection has been released back to the pool)_conrInterfaceErrorformatrr+)selfargskwargsr( meth_names r,call_con_methodHPoolConnectionProxyMeta._wrap_connection_method..call_con_method=seyy  //DDJF!E#$$ 499.. :D 3D3F3 3r.)r4rr5rr6rreturnr)r markcoroutinefunction)r7r)r8s` r,r/PoolConnectionProxyMeta._wrap_connection_method9s! 4   ( ( 9r.) r$strr%ztuple[Type[Any], ...]r&zdict[str, Any]rboolr:r)r7r>r)r?r:zCallable[..., Any]) __name__ __module__ __qualname____firstlineno__r" staticmethodr__static_attributes__ __classcell__)r+s@r,rrsn 77%7 7  7 !776%) r.rcL\rSrSrSrSSjrS SjrS SjrS SjrSr g) PoolConnectionProxyN)r1_holderc>X lXlURU5 gN)r1rJ _set_proxy)r4holdercons r,__init__PoolConnectionProxy.__init__Ts   tr.c.[URU5$rL)rr1)r4attrs r, __getattr__PoolConnectionProxy.__getattr__[styy$''r.cjURcgURSsolURS5 U$rL)r1rM)r4rOs r,_detachPoolConnectionProxy._detach_s/ 99  DY t r.cURc-SRURR[ U5S9$SRURRUR[ U5S9$)Nz <{classname} [released] {id:#x}>) classnameidz<{classname} {con!r} {id:#x}>)rZrOr[)r1r3r+r@r[r4s r,__repr__PoolConnectionProxy.__repr__gsn 99 5<<..11bh=@ @399..11tyyRX:O Or.N)rNPoolConnectionHolderrOzconnection.Connectionr:None)rSr>r:r)r:zOptional[connection.Connection])r:r>) r@rArBrC __slots__rPrTrWr]rEr=r.r,rHrHNs6$I*1F (Or.rHT) metaclassrc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSSjrSrg)r_p) r1_pool_loop_proxy _max_queries_setup_max_inactive_time_in_use_inactive_callback_timeout _generationcXlSUlSUlX lX@lX0lSUlSUlSUlSUl grL) rer1rgrhrjrirlrkrmrn)r4pool max_queriessetupmax_inactive_times r,rPPoolConnectionHolder.__init__xsF 59 59 '"3 6:15 )- *.r.cjURSL=(a URR5(+$rL)r1 is_closedr\s r, is_connected!PoolConnectionHolder.is_connecteds&yy$BTYY-@-@-B)BBr.c$UR(+$rLrkr\s r,is_idlePoolConnectionHolder.is_idles<<r.c# URb[R"S5eURR 5IShvN UlURR UlUR 5 UR5 gNE7f)NzMPoolConnectionHolder.connect() called while another connection already exists)r1rInternalClientErrorre_get_new_connectionrn_maybe_cancel_inactive_callback_setup_inactive_callbackr\s r,connectPoolConnectionHolder.connectso 99 00,- -**88:: ::11 ,,. %%';sAB B AB cZ# URbURR5(a SUlUR5IShvN OURURR:waeURR R URRURS95 SUlUR5IShvN UR5 [XR5=Ul nURbURU5IShvN URR R!5UlU$GN NN4![[R4a1nURR5IShvN Ue!Ue=fSnAff=f7f)Ntimeout)r1rvrrnrerf create_taskclosermrrHrgri ExceptionasyncioCancelledError create_futurerk)r4proxyexs r,acquirePoolConnectionHolder.acquiresE 99  3 3 5 5DI,,.   !7!7 7 JJ   ( (  6 8DI,,.  ,,.1$ BB e ;; " kk%(((zz''557  A ! !)w556   ))//+++H"H syAF+ E B F+E=F+E&E'E+,F+F+EF(8FFFF#F  F##F((F+c# URc[R"S5eURR 5(agSUlURR RUR:a"URRUS9IShvN gURURR:wa"URRUS9IShvN gUnURR R5(at[R"5n[R "URR R#5U5IShvN UbU[R"5U- -nURR$b[R&"U5IShvN URR%5IShvN URR%UR5IShvN SSS5IShvN O"URR)US9IShvN UR35 UR55 gGNGNGNNNNeNW!,IShvN (df  NI=fNQ![*[,R.4a(nURR15 Ue!Ue=fSnAff=f7f)NzAPoolConnectionHolder.release() called on a free connection holderr)rkrr~r1rvrm _protocol queries_countrhrrnre_is_cancellingtime monotonicr wait_for_wait_for_cancellation_resetrresetrrr terminate_releaser)r4rbudgetstartedrs r,releasePoolConnectionHolder.releases/ << 00+, , 99     99   , ,0A0A A))//'/2 2 2    tzz55 5))//'/2 2 2  Fyy""1133..*ooII''>>@%dnn.88Fzz  ,!>>&11))**,,,**++DII666211iioofo555  %%'[ 3 32,6211167112   ##%b sBKIAKIK$AKKKK  KcT# URcgURIShvN gN7frLrzr\s r,wait_until_released(PoolConnectionHolder.wait_until_releaseds <<  ,,  s (&(cp# URb#URR5IShvN ggN7frL)r1rr\s r,rPoolConnectionHolder.closes/ 99 ))//# # # ! $s +646cTURbURR5 ggrL)r1rr\s r,rPoolConnectionHolder.terminates# 99  II   ! !r.cURb[R"S5eUR(a@URR R URUR5Ulgg)Nz/pool connection inactivity timer already exists)rlrr~rjrerf call_later_deactivate_inactive_connectionr\s r,r-PoolConnectionHolder._setup_inactive_callbackse  " " .00AC C  " "&*jj&6&6&A&A'')M)M'OD # #r.cbURb"URR5 SUlggrL)rlcancelr\s r,r4PoolConnectionHolder._maybe_cancel_inactive_callbacks-  " " .  # # * * ,&*D # /r.cURb[R"S5eURb+URR 5 UR 5 gg)Nz/attempting to deactivate an acquired connection)rkrr~r1r_release_on_closer\s r,r4PoolConnectionHolder._deactivate_inactive_connection"sU << #00AC C 99  II   !  " " $ !r.cRUR5 UR5 SUlgrL)rrr1r\s r,r&PoolConnectionHolder._release_on_close0s ,,.  r.cHURcgURR5(dURRS5 SUlURb!URR 5 SUlUR R RU5 g)zRelease this connection holder.N)rkdone set_resultrgrWre_queue put_nowaitr\s r,rPoolConnectionHolder._release5sx <<  ||  "" LL # #D )  ;; " KK   !DK $$T*r.) r1rnrkrlrjrhrergrirmN) rpz'Pool'rqfloatrrz:Optional[Callable[[PoolConnectionProxy], Awaitable[None]]]rsrr:r`)r:r?)r:r`)r:rH)rOptional[float]r:r`)r@rArBrCrarPrwr{rrrrrrrrrrrrEr=r.r,r_r_ps I // / J / ! / /*C  (#J=(~ $ " O+ % +r.r_c\rSrSrSrSrSSSSS.SjrSrSrS r S r S r S r S r S0SjrSrSS.S1SjjrSS.S2SjjrSSS.S3SjjrSSS.SjrSSS.SjrSSS.SjrSSSSSSSSSSSSS. SjrSSSSSSSSSSS. SjrSSSSSSSSSSSSSSSSS.SjrSSSSS .S!jrSS.S"jrS#rSS.S$jrS%rS&rS'rS(r S)r!S*r"S+r#S,r$S-r%S.r&S/r'g)4PooliIauA connection pool. Connection pool can be used to manage a set of connections to the database. Connections are first acquired from the pool, then used, and then released back to the pool. Once a connection is released, it's reset to close all open cursors and other resources *except* prepared statements. Pools are created by calling :func:`~asyncpg.pool.create_pool`. )rrf_minsize_maxsize_init_connectr _connect_args_connect_kwargs_holders _initialized _initializing_closing_closed_connection_class _record_classrnrirh!_max_inactive_connection_lifetimeN)rrrinitrc :[U 5S:a[R"S[SS9 U c[R "5n XlUS::a [S5eUS:a [S5eX:a [S5eUS::a [S 5eUS:a [S 5e[U [R5(d[S RU 55e[U [R5(d[S RU 55eXlX l/UlS UlS UlSUlXlXlS UlS UlSUlUbUO[R4UlXlXlX`lXplXl X0l!UUl"g)Nr zPassing multiple positional arguments to asyncpg.Pool constructor is deprecated and will be removed in asyncpg 0.17.0. The non-deprecated form is asyncpg.Pool(, **kwargs)) stacklevelrz,max_size is expected to be greater than zeroz3min_size is expected to be greater or equal to zeroz!min_size is greater than max_sizez/max_queries is expected to be greater than zerozKmax_inactive_connection_lifetime is expected to be greater or equal to zerozMconnection_class is expected to be a subclass of asyncpg.Connection, got {!r}zErecord_class is expected to be a subclass of asyncpg.Record, got {!r}F)#lenwarningswarnDeprecationWarningrget_event_looprf ValueError issubclassr r TypeErrorr3rRecordrrrrrrrrrrrnrrrrrirrrhr)r4min_sizemax_sizerq max_inactive_connection_lifetimerrrrrloopconnection_class record_class connect_argsconnect_kwargss r,rP Pool.__init__\s | q MM0#q  2 <))+D q=KL L a<EG G  @A A ! NO O +a /#$ $*J,A,ABB//5v6F/GI I,88++16,+?A A!   !" !1)  #*#6J t}}%A% --"&"H"Hkk #B MM  $ KK " "2 && ==}}R(H""$ $ $}}q " &x cr0B'CDEAMMA--!((6 E nnm444!  %5s%CE+E'B E+E) E+)E+c@UR=(d UR$)zOReturn ``True`` if the pool is closing or is closed. .. versionadded:: 0.28.0 )rrr\s r, is_closingPool.is_closings ||,t}},r.c:[SUR55$)zQReturn the current number of connections in this pool. .. versionadded:: 0.25.0 c3># UHoR5v M g7frL)rw.0hs r, Pool.get_size..s;]>>##]ssumrr\s r,get_size Pool.get_sizes ;T]];;;r.cUR$)zQReturn the minimum number of connections in this pool. .. versionadded:: 0.25.0 )rr\s r, get_min_sizePool.get_min_size }}r.cUR$)zYReturn the maximum allowed number of connections in this pool. .. versionadded:: 0.25.0 )rr\s r, get_max_sizePool.get_max_sizerr.c:[SUR55$)zVReturn the current number of idle connections in this pool. .. versionadded:: 0.25.0 c3l# UH+oR5=(a UR5v M- g7frL)rwr{rs r,r%Pool.get_idle_size..s#K]>>#3 3]s24rr\s r, get_idle_sizePool.get_idle_sizes KT]]KKKr.c  U/UlX lg)aZSet the new connection arguments for this pool. The new connection arguments will be used for all subsequent new connection attempts. Existing connections will remain until they expire. Use :meth:`Pool.expire_connections() ` to expedite the connection expiry. :param str dsn: Connection arguments specified using as a single string in the following format: ``postgres://user:pass@host:port/database?option=value``. :param \*\*connect_kwargs: Keyword arguments for the :func:`~asyncpg.connection.connect` function. .. versionadded:: 0.16.0 N)rr)r4dsnrs r,set_connect_argsPool.set_connect_argss*"U-r.c# UR"URURURURS.UR D6IShvN n[ XR5(dURnURSUR3n[U5nURS:Xa URnOURSUR3n[R"SUSUS35eURbURU5IShvN U$U$NN ![[R4a'nUR!5IShvN Ue!Ue=fSnAff=f7f)N)rrr.builtinsz9expected pool connect callback to return an instance of 'z', got '')rrrfrrr isinstancerAr@typerr2rrrrr)r4rOgoodgood_nbadbad_nrs r,rPool._get_new_connectionsTMM   !33++  ""   #5566))D($--9Fs)C~~+ >>*!CLL>:++8<wa1  :: ! jjo%% s K ,&w556   ))+%%H"H sgA E'DB2E'D#D!D#E'!D##E$>EEEEEEE$$E'rc# UR5IShvN nUR"U/UQ7SU06IShvN sSSS5IShvN $N3NN !,IShvN (df  g=f7f)zExecute an SQL command (or commands). Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.execute() `. .. versionadded:: 0.10.0 Nr)rexecute)r4queryrr5rOs r,r Pool.executeAsD<<>>SUCTC7CC">>C">>>SA+A A+AA A A+AA+ AA+A(A  A($A+c# UR5IShvN nURXUS9IShvN sSSS5IShvN $N-NN !,IShvN (df  g=f7f)aExecute an SQL *command* for each sequence of arguments in *args*. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.executemany() `. .. versionadded:: 0.10.0 Nr)r executemany)r4commandr5rrOs r,r$Pool.executemanyRs> <<>>SHH">>H">>>RA%AA%A AA  A%A A%A  A% A"A  A"A%rrc# UR5IShvN nUR"U/UQ7UUS.6IShvN sSSS5IShvN $N4NN !,IShvN (df  g=f7f)aRun a query and return the results as a list of :class:`Record`. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetch() `. .. versionadded:: 0.10.0 Nr()rfetchr4r rrr5rOs r,r* Pool.fetchesV<<>>S ) ">>">>>SA,A A,AAA A,AA,AA,A)A  A)%A,rcolumnrc# UR5IShvN nUR"U/UQ7X#S.6IShvN sSSS5IShvN $N3NN !,IShvN (df  g=f7f)zRun a query and return a value in the first row. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetchval() `. .. versionadded:: 0.10.0 Nr.)rfetchval)r4r r/rr5rOs r,r1 Pool.fetchval|sQ<<>>S>>%+>>">>>">>>r"c# UR5IShvN nUR"U/UQ7UUS.6IShvN sSSS5IShvN $N4NN !,IShvN (df  g=f7f)zRun a query and return the first row. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetchrow() `. .. versionadded:: 0.10.0 Nr()rfetchrowr+s r,r4 Pool.fetchrowsV<<>>S ) ">>">>>r-c# UR5IShvN nURXX4S9IShvN sSSS5IShvN $N-NN !,IShvN (df  g=f7f)a6Run a query for each sequence of arguments in *args* and return the results as a list of :class:`Record`. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.fetchmany() `. .. versionadded:: 0.30.0 Nr()r fetchmany)r4r r5rrrOs r,r7Pool.fetchmanysH<<>>SW'">>">>>r') columns schema_namerr3oids delimiternullheaderquoteescape force_quoteencodingc # UR5IShvN nURUUUUUUUUU U U U U US9IShvN sSSS5IShvN $N9NN !,IShvN (df  g=f7f)a Copy table contents to a file or file-like object. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_from_table() `. .. versionadded:: 0.24.0 N) outputr9r:rr3r;r<r=r>r?r@rArB)rcopy_from_table)r4 table_namerDr9r:rr3r;r<r=r>r?r@rArBrOs r,rEPool.copy_from_tableso6<<>>S,,'#'!-">>">>>sSA1AA1 AAA A1 A A1AA1A.A  A.*A1) rr3r;r<r=r>r?r@rArBc # UR5IShvN nUR"U/U Q7UUUUUUUU U U U S. 6IShvN sSSS5IShvN $N=NN !,IShvN (df  g=f7f)aCopy the results of a query to a file or file-like object. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_from_query() `. .. versionadded:: 0.24.0 N) rDrr3r;r<r=r>r?r@rArB)rcopy_from_query)r4r rDrr3r;r<r=r>r?r@rArBr5rOs r,rIPool.copy_from_queryss2<<>>S,,#'!">>">>>UA5AA5$AAA A5AA5AA5A2!A$ " A2.A5)r9r:rr3r;freezer<r=r>r?r@rAforce_not_null force_nullrBwherec# UR5IShvN nURUUUUUUUUU U U U U UUUUUS9IShvN sSSS5IShvN $N=NN !,IShvN (df  g=f7f)zCopy data to the specified table. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_to_table() `. .. versionadded:: 0.24.0 N)sourcer9r:rr3r;rLr<r=r>r?r@rArMrNrBrO)r copy_to_table)r4rFrQr9r:rr3r;rLr<r=r>r?r@rArMrNrBrOrOs r,rRPool.copy_to_tables{><<>>S**'#'-%!%+">>">>>rK)r9r:rrOc # UR5IShvN nURUUUUUUS9IShvN sSSS5IShvN $N1NN !,IShvN (df  g=f7f)a%Copy a list of records to the specified table using binary COPY. Pool performs this operation using one of its connections. Other than that, it behaves identically to :meth:`Connection.copy_records_to_table() `. .. versionadded:: 0.24.0 N)recordsr9r:rrO)rcopy_records_to_table)r4rFrUr9r:rrOrOs r,rVPool.copy_records_to_table7sW&<<>>S22' 3">>">>>sSA)A A)AA A A)A A) A A)A&A  A&"A)c[X5$)aAcquire a database connection from the pool. :param float timeout: A timeout for acquiring a Connection. :return: An instance of :class:`~asyncpg.connection.Connection`. Can be used in an ``await`` expression or with an ``async with`` block. .. code-block:: python async with pool.acquire() as con: await con.execute(...) Or: .. code-block:: python con = await pool.acquire() try: await con.execute(...) finally: await pool.release(con) )PoolAcquireContext)r4rs r,r Pool.acquireTs."$00r.c^^# UU4SjnTR(a[R"S5eTR5 TcU"5IShvN $[R "U"5TS9IShvN $N&N7f)Nc># TRR5IShvN nUR5IShvN nTUlU$N&N![[ R 4a TRRU5 ef=f7frL)rgetrrmrrrr)rrr4rs r, _acquire_impl$Pool._acquire.._acquire_implnsp{{((B  jjl*&  )*w556  &&r* s5BABA A A B A 7BBzpool is closingr)rrr2 _check_initr r)r4rr^s`` r,_acquire Pool._acquiremsi  ==++,=> >  ?&( (22 2)2s$A A;A7!A;2A93A;9A;c# [U5[LdURRULa#[R "SR US95eURcgUR5 URR5 URnUc URn[R"URU55IShvN $N7f)aRelease a database connection back to the pool. :param Connection connection: A :class:`~asyncpg.connection.Connection` object to release. :param float timeout: A timeout for releasing the connection. If not specified, defaults to the timeout provided in the corresponding call to the :meth:`Pool.acquire() ` method. .. versionchanged:: 0.14.0 Added the *timeout* parameter. zWPool.release() received invalid connection: {connection!r} is not a member of this poolr N)rrHrJrerr2r3r1r` _on_releasermrshieldr)r4r rrs r,r Pool.releases  $7 7""((4++>>Df)?E?+, , ?? "   ##%    ?kkG ^^BJJw$78888sC C C Cc# UR(agUR5 SUlSnURR SUR 5nUR Vs/sHo"R5PM nn[R"U6IShvN UR Vs/sHo"R5PM nn[R"U6IShvN UbUR5 SUlSUlgs snfNos snfN3![[R4a UR5 ef=f!UbUR5 SUlSUlf=f7f)a2Attempt to gracefully close all connections in the pool. Wait until all pool connections are released, close them and shut down the pool. If any error (including cancellation) occurs in ``close()`` the pool will terminate by calling :meth:`Pool.terminate() `. It is advisable to use :func:`python:asyncio.wait_for` to set a timeout. .. versionchanged:: 0.16.0 ``close()`` now waits until all pool connections are released before closing them and the pool. Errors raised in ``close()`` will cause immediate pool termination. NT<F)rr`rrfr_warn_on_long_closerrrrrrrrr)r4warning_callbackr release_coros close_coross r,r Pool.closes@ <<    "#zz44D,, . 48==B3@R&&(= B..-0 0 0&*]]4%2r ] 4..+. . . + '')DL!DM!B 04 .7112  NN     + '')DL!DMsd,E!4D #C>;D DD &D>D D D "E!>D D ,D88D;;#EE!c.[RS5 g)NzPool.close() is taking over 60 seconds to complete. Check if you have any unreleased connections left. Use asyncio.wait_for() to set a timeout for Pool.close().)loggerwarningr\s r,riPool._warn_on_long_closes' (r.cUR(agUR5 URHnUR5 M SUlg)z&Terminate all connections in the pool.NT)rr`rrr4rs r,rPool.terminates6 <<  --B LLN  r.c6# U=RS- slg7f)zExpire all currently open connections. Cause all currently open connections to get replaced on the next :meth:`~asyncpg.pool.Pool.acquire()` call. .. versionadded:: 0.16.0 r N)rnr\s r,expire_connectionsPool.expire_connectionss AscUR(d=UR(a[R"S5e[R"S5eUR(a[R"S5eg)Nzipool is being initialized, but not yet ready: likely there is a race between creating a pool and using itzpool is not initializedr)rrrr2rr\s r,r`Pool._check_inits^  !! //  ++,EF F <<++,<= = r.c|URH,nURcMURR5 M. grL)rr1_drop_local_statement_cacherss r,_drop_statement_cachePool._drop_statement_caches*--Bww"335 r.c|URH,nURcMURR5 M. grL)rr1_drop_local_type_cacherss r,_drop_type_cachePool._drop_type_caches*--Bww"..0 r.c>UR5R5$rL)r __await__r\s r,rPool.__await__s""$..00r.cB# UR5IShvN U$N7frL)rr\s r, __aenter__Pool.__aenter__ s!!!###  $s c@# UR5IShvN gN7frL)r)r4excs r, __aexit__Pool.__aexit__sjjls )rrrrrrrnrrrrrfrrhrrrrrrirL)r r>rrr:r>)r%r>rr)r:list)(r@rArBrCrrarPrrrrrrr rrrr$r*r1r4r7rErIrRrVrrarrrirrvr`r|rrrrrEr=r.r,rrIsIO-b% 5B-<L.0&X"& DD! D D,"& II ! I.   .34T >48d"7;*  !+d  (^  )3t:"&122048$9L+"Z(  >6 1 1r.rcP\rSrSrSrS SjrSrS S SjjrSrSr g) rYi)rr rrpc8XlX lSUlSUlg)NF)rprr r)r4rprs r,rPPoolAcquireContext.__init__s   r.c# URcUR(a[R"S5eURR UR 5IShvN UlUR$N7f)Nz a connection is already acquired)r rrr2rprarr\s r,rPoolAcquireContext.__aenter__sT ?? &$))++,NO O $ 2 24<< @@AsAA7A5 A7Nc# SUlURnSUlURRU5IShvN gN7fNT)rr rpr)r4exc_typeexc_valexc_tbrOs r,rPoolAcquireContext.__aexit__#s6  ooii$$$s9AAAcvSUlURRUR5R 5$r)rrprarrr\s r,rPoolAcquireContext.__await__.s+ yy!!$,,/99;;r.)r rrpr)rprrrr:r`)NNN)rzOptional[Type[BaseException]]rzOptional[BaseException]rzOptional[TracebackType]r:r`) r@rArBrCrarPrrrrEr=r.r,rYrYsL9I 37+/*. %/ %) %( %  %` and :meth:`Connection.cursor() ` become invalid once the connection is released. Likewise, all notification and log listeners are removed, and ``asyncpg`` will issue a warning if there are any listener callbacks registered on a connection that is being released to the pool. :param str dsn: Connection arguments specified using as a single string in the following format: ``postgres://user:pass@host:port/database?option=value``. :param \*\*connect_kwargs: Keyword arguments for the :func:`~asyncpg.connection.connect` function. :param Connection connection_class: The class to use for connections. Must be a subclass of :class:`~asyncpg.connection.Connection`. :param type record_class: If specified, the class to use for records returned by queries on the connections in this pool. Must be a subclass of :class:`~asyncpg.Record`. :param int min_size: Number of connection the pool will be initialized with. :param int max_size: Max number of connections in the pool. :param int max_queries: Number of queries after a connection is closed and replaced with a new connection. :param float max_inactive_connection_lifetime: Number of seconds after which inactive connections in the pool will be closed. Pass ``0`` to disable this mechanism. :param coroutine connect: A coroutine that is called instead of :func:`~asyncpg.connection.connect` whenever the pool needs to make a new connection. Must return an instance of type specified by *connection_class* or :class:`~asyncpg.connection.Connection` if *connection_class* was not specified. :param coroutine setup: A coroutine to prepare a connection right before it is returned from :meth:`Pool.acquire()`. An example use case would be to automatically set up notifications listeners for all connections of a pool. :param coroutine init: A coroutine to initialize a connection when it is created. An example use case would be to setup type codecs with :meth:`Connection.set_builtin_type_codec() <\ asyncpg.connection.Connection.set_builtin_type_codec>` or :meth:`Connection.set_type_codec() <\ asyncpg.connection.Connection.set_type_codec>`. :param coroutine reset: A coroutine to reset a connection before it is returned to the pool by :meth:`Pool.release()`. The function is supposed to reset any changes made to the database session so that the next acquirer gets the connection in a well-defined state. The default implementation calls :meth:`Connection.reset() <\ asyncpg.connection.Connection.reset>`, which runs the following:: SELECT pg_advisory_unlock_all(); CLOSE ALL; UNLISTEN *; RESET ALL; The exact reset query is determined by detected server capabilities, and a custom *reset* implementation can obtain the default query by calling :meth:`Connection.get_reset_query() <\ asyncpg.connection.Connection.get_reset_query>`. :param loop: An asyncio event loop instance. If ``None``, the default event loop will be used. :return: An instance of :class:`~asyncpg.pool.Pool`. .. versionchanged:: 0.10.0 An :exc:`~asyncpg.exceptions.InterfaceError` will be raised on any attempted operation on a released connection. .. versionchanged:: 0.13.0 An :exc:`~asyncpg.exceptions.InterfaceError` will be raised on any attempted operation on a prepared statement or a cursor created on a connection that has been released to the pool. .. versionchanged:: 0.13.0 An :exc:`~asyncpg.exceptions.InterfaceWarning` will be produced if there are any active listeners (added via :meth:`Connection.add_listener() ` or :meth:`Connection.add_log_listener() `) present on the connection at the moment of its release to the pool. .. versionchanged:: 0.22.0 Added the *record_class* parameter. .. versionchanged:: 0.30.0 Added the *connect* and *reset* parameters. ) rrrrrqrrrrrrr)r) rrrrqrrrrrrrrrrs r, create_poolr3sE~   )!  )I   r.rL)# __future__rrcollections.abcrrrrloggingrtypesrtypingrrr rr r rr getLoggerr@rorr_ConnectionProxyrHr_rrYrrrr=r.r,rs#/ &&   8 $/d/dO*55$;#ODV+V+rG G T<<@m!16!+!6!6%__mr.