V.j TddlZddlZddlZddlZddlZddlZddlmZddlmZddlm Z ddlm Z eje Z GddeZGd d ej ed ZGd dZGddZGddZddddddddddej*e j,d dZy)N)compat connection) exceptions)protocolc4eZdZddfd ZedZxZS)PoolConnectionProxyMetaF)wrapc|rttjD]}|jds||vrt tj|}t j |sIt j|}|j||}tj||}|||<d|vrtjj|d<t |5||||S)N___doc__)dirr Connection startswithgetattrinspect isfunctioniscoroutinefunction_wrap_connection_method functoolsupdate_wrapperrsuper__new__) mclsnamebasesdctr attrnamemeth iscoroutinewrapper __class__s NC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\asyncpg/pool.pyrzPoolConnectionProxyMeta.__new__s  5 56&&s+x3z44h?))$/%99$? 66xM#227DA 'H 7#!+!6!6!>!>IwtT5#66c@fd}|rtj||S)Nc|j$tjdjt |jj }||jg|i|S)NzJcannot call Connection.{}(): connection has been released back to the pool)_conrInterfaceErrorformatrr#)selfargskwargsr meth_names r$call_con_methodzHPoolConnectionProxyMeta._wrap_connection_method..call_con_method0seyy  //DDJF!E#$$ 499.. :D 3D3F3 3r%)rmarkcoroutinefunction)r.r!r/s` r$rz/PoolConnectionProxyMeta._wrap_connection_method.s! 4   ( ( 9r%)__name__ __module__ __qualname__r staticmethodr __classcell__)r#s@r$r r s057(r%r c`eZdZdZdddej fdZdZdej fdZd Z y ) PoolConnectionProxy)r(_holderholderPoolConnectionHolderconcB||_||_|j|yN)r(r8 _set_proxy)r+r9r;s r$__init__zPoolConnectionProxy.__init__Gs   tr%c.t|j|Sr=)rr()r+attrs r$ __getattr__zPoolConnectionProxy.__getattr__Mstyy$''r%returncj|jy|jdc}|_|jd|Sr=)r(r>)r+r;s r$_detachzPoolConnectionProxy._detachQs1 99  DTY t r%c|j0dj|jjt |Sdj|jj|jt |S)Nz <{classname} [released] {id:#x}>) classnameidz<{classname} {con!r} {id:#x}>)rGr;rH)r(r*r#r1rHr+s r$__repr__zPoolConnectionProxy.__repr__Ysn 99 5<<..11bh=@ @399..11tyyRX:O Or%N) r1r2r3 __slots__rrr?rBrErJr%r$r7r7AsA$I5 ++ (..Or%r7T) metaclassr cjeZdZdZdZdZdZdZdefdZ dZ d Z d Z d Z d Zd ZdZdZdZy)r:) r(_pool_loop_proxy _max_queries_setup_max_inactive_time_in_use_inactive_callback_timeout _generationc||_d|_d|_||_||_||_d|_d|_d|_d|_ yr=) rOr(rQrRrTrSrVrUrWrX)r+pool max_queriessetupmax_inactive_times r$r?zPoolConnectionHolder.__init__jsL   '"3 "&  r%cX|jduxr|jj Sr=)r( is_closedrIs r$ is_connectedz!PoolConnectionHolder.is_connectedxs&yy$BTYY-@-@-B)BBr%c|j Sr=rUrIs r$is_idlezPoolConnectionHolder.is_idle{s<<r%cK|jtjd|jj d{|_|jj |_|j |jy7Ew)NzMPoolConnectionHolder.connect() called while another connection already exists)r(rInternalClientErrorrO_get_new_connectionrX_maybe_cancel_inactive_callback_setup_inactive_callbackrIs r$connectzPoolConnectionHolder.connect~sp 99 00,- -**88:: ::11 ,,. %%';s?B BAB rCcPK|j|jjr d|_|jd{n|j|jjk7rh|jj j |jj|jd|_|jd{|jt||jx|_ }|j |j|d{|jj j!|_|S7774#ttjf$r1} |jjd{7|#|xYwd}~wwxYww)Ntimeout)r(r_rirXrOrP create_taskcloserWrgr7rQrS ExceptionasyncioCancelledError create_futurerU)r+proxyexs r$acquirezPoolConnectionHolder.acquiresG 99  3 3 5DI,,.   !7!7 7 JJ   ( (  6 8DI,,.  ,,.1$ BB e ;; " kk%(((zz''557  A ! !)w556   ))//+++H"H syAF&EB F&E=F&E"E#E',F&F&EF#3FFFFFFF##F&czK|jtjd|jj ryd|_|jj j|jk\r%|jj|d{y|j|jjk7r%|jj|d{y |}|jj jrptj}tj |jj j#|d{||tj|z z}|jj$~tj&|4d{|jj%d{|jj%|jd{dddd{n$|jj)|d{|j3|j5y77y7777f7X#1d{7swYCxYw7J#t*t,j.f$r(} |jj1|#|xYwd}~wwxYww)NzAPoolConnectionHolder.release() called on a free connection holderrk)rUrrer(r_rW _protocol queries_countrRrnrXrO_is_cancellingtime monotonicrwait_for_wait_for_cancellation_resetrlresetrorprq terminate_releaserh)r+rlbudgetstartedrts r$releasezPoolConnectionHolder.releases1 << 00+, , 99     99   , ,0A0A A))//'/2 2 2    tzz55 5))//'/2 2 2  Fyy""113..*ooII''>>@%dnn.88Fzz  ,!>>&11))**,,,**++DII666211iioofo555  %%'[ 3 32,6211167112   ##%b sBJ;IAJ;IJ;!A5I7IAI7&I'I7*I I ,I 5I6I : I7I$I7*I5+I7/"J;J;I7I7I I I7 I2&I) 'I2.I77J8J-+J3-J00J33J88J;cRK|jy|jd{y7wr=rbrIs r$wait_until_releasedz(PoolConnectionHolder.wait_until_releaseds <<  ,,  s '%'cnK|j#|jjd{yy7wr=)r(rnrIs r$rnzPoolConnectionHolder.closes0 99 ))//# # # ! $s *535cR|j|jjyyr=)r(rrIs r$rzPoolConnectionHolder.terminates# 99  II   ! !r%c|jtjd|jr@|jj j |j|j|_yy)Nz/pool connection inactivity timer already exists)rVrrerTrOrP call_later_deactivate_inactive_connectionrIs r$rhz-PoolConnectionHolder._setup_inactive_callbackse  " " .00AC C  " "&*jj&6&6&A&A'')M)M'OD # #r%c`|j"|jjd|_yyr=)rVcancelrIs r$rgz4PoolConnectionHolder._maybe_cancel_inactive_callbacks-  " " .  # # * * ,&*D # /r%c|jtjd|j+|jj |j yy)Nz/attempting to deactivate an acquired connection)rUrrer(r_release_on_closerIs r$rz4PoolConnectionHolder._deactivate_inactive_connection sU << #00AC C 99  II   !  " " $ !r%cR|j|jd|_yr=)rgrr(rIs r$rz&PoolConnectionHolder._release_on_closes ,,.  r%c:|jy|jjs|jjdd|_|j!|jj d|_|j j j|y)zRelease this connection holder.N)rUdone set_resultrQrErO_queue put_nowaitrIs r$rzPoolConnectionHolder._release su <<  ||  " LL # #D )  ;; " KK   !DK $$T*r%N)r1r2r3rKr?r`rcrir7rurrrnrrhrgrrrrLr%r$r:r:bs[ I  C  (#2#J=(~ $ " O+ % +r%r:ceZdZdZdZddddddZdZdZdZd Z d Z d Z d Z d2d Z dZdddededefdZdddedefdZddddefdZddddZddddZddddZddddddddddddd dZddddddddddd d Zddddddddddddddddd!d"Zddddd#d$Zddd%Zd&Zddd'Zd(Zd)Z d*Z!d+Z"d,Z#d-Z$d.Z%d/Z&d0Z'd1Z(y)3PoolaA 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`. )rrP_minsize_maxsize_init_connectr~ _connect_args_connect_kwargs_holders _initialized _initializing_closing_closed_connection_class _record_classrXrSrR!_max_inactive_connection_lifetimeN)rir\initrc 0t| dkDrtjdtd| t j } | |_|dkr td|dkr td||kDr td|dkr td |dkr td t| tjstd j| t| tjstd j| ||_||_g|_d |_d |_d|_| |_| |_d |_d |_d|_||ntj4|_| |_| |_||_||_||_ ||_!||_"y)NrzPassing 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)#lenwarningswarnDeprecationWarningrpget_event_looprP ValueError issubclassrr TypeErrorr*rRecordrrrrrrrrrrrXrirrrrSrr~rRr)r+min_sizemax_sizer[ max_inactive_connection_lifetimerir\rrloopconnection_class record_class connect_argsconnect_kwargss r$r?z Pool.__init__Gs | q MM0#q  2 <))+D q=KL L a<EG G h @A A ! NO O +a /#$ $*J,A,AB//5v6F/GI I,8++16,+?A A!    !" !1)  #*#6J t}}%A% --"&"H"Hkk #B MM  $ KK " "2 && ==}}R(H""$ $ $}}q " &x cr0B'CDEArDMMA--!((6 E nnm444!  %5s%CE&E"BE&E$E&$E&c6|jxs |jS)z_Return ``True`` if the pool is closing or is closed. .. versionadded:: 0.28.0 )rrrIs r$ is_closingzPool.is_closings ||,t}},r%c:td|jDS)zaReturn the current number of connections in this pool. .. versionadded:: 0.25.0 c3<K|]}|jywr=)r`.0hs r$ z Pool.get_size..s;]1>>#]ssumrrIs r$get_sizez Pool.get_sizes ;T]];;;r%c|jS)zaReturn the minimum number of connections in this pool. .. versionadded:: 0.25.0 )rrIs r$ get_min_sizezPool.get_min_size }}r%c|jS)ziReturn the maximum allowed number of connections in this pool. .. versionadded:: 0.25.0 )rrIs r$ get_max_sizezPool.get_max_sizerr%c:td|jDS)zfReturn the current number of idle connections in this pool. .. versionadded:: 0.25.0 c3`K|]&}|jxr|j(ywr=)r`rcrs r$rz%Pool.get_idle_size..s&K]1>>#3 3]s,.rrIs r$ get_idle_sizezPool.get_idle_sizes KT]]KKKr%c "|g|_||_y)aSet 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)r+dsnrs r$set_connect_argszPool.set_connect_argss*"U-r%cK|j|j|j|j|jd|j d{}t ||js|j}|jd|j}t|}|jdk(r |j}n|jd|j}tjd|d|d|j |j|d{|S|S77 #ttjf$r'} |j!d{7|#|xYwd}~wwxYww)N)rrr.builtinsz9expected pool connect callback to return an instance of 'z', got '')rrrPrrr isinstancer2r1typerr)rrorprqrn)r+r;goodgood_nbadbad_nrts r$rfzPool._get_new_connectionsW!DMM   !33++  ""   #t556))D($--9Fs)C~~+ >>*!CLL>:++8<wa1  :: ! jjo%% s K ,&w556   ))+%%H"H sgA EDB+E;DDDEDE6E E  EEEEEErkqueryrlrCcK|j4d{}|j|g|d|id{cdddd{S7377 #1d{7swYyxYww)aExecute 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 Nrl)ruexecute)r+rrlr,r;s r$rz Pool.execute,sJ<<>>S$UCTC7CC">>C">>>sSA&A A&AA A A&AA& AA&A#A A#A&commandcK|j4d{}|j|||d{cdddd{S7177 #1d{7swYyxYww)aCExecute 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 Nrk)ru executemany)r+rr,rlr;s r$rzPool.executemany8sD<<>>S$HH">>H">>>sSA$A A$AA A A$A A$ A A$A!A A!A$rlrcK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)a-Run 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)rufetchr+rrlrr,r;s r$rz Pool.fetchEs\<<>>S" ) ">>">>>SA'A A'AAA A'AA'AA'A$A A$ A'rcolumnrlcK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)a+Run 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)rufetchval)r+rrrlr,r;s r$rz Pool.fetchval\sY<<>>S%>>%+W>>">>>">>>rcK|j4d{}|j|g|||dd{cdddd{S7477 #1d{7swYyxYww)aRun 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)rufetchrowrs r$rz Pool.fetchrowjs\<<>>S% ) ">>">>>rcK|j4d{}|j||||d{cdddd{S7277 #1d{7swYyxYww)anRun 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)ru fetchmany)r+rr,rlrr;s r$rzPool.fetchmany{sP<<>>StW<'">>">>>sSA%A A%AA A A%AA% AA%A"A A"A%) columns schema_namerlr*oids delimiternullheaderquoteescape force_quoteencodingc K|j4d{}|j||||||||| | | | | |d{cdddd{S7<77 #1d{7swYyxYww)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) outputrrrlr*rrrrrrrr)rucopy_from_table)r+ table_namer rrrlr*rrrrrrrrr;s r$r zPool.copy_from_tabless6<<>>S,,'#'!-">>">>>sTA/AA/#AAA A/AA/AA/A, A# !A,(A/) rlr*rrrrrrrrc K|j4d{}|j|g| |||||||| | | | d d{cdddd{S7=77 #1d{7swYyxYww)aCCopy 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) r rlr*rrrrrrrr)rucopy_from_query)r+rr rlr*rrrrrrrrr,r;s r$rzPool.copy_from_querysy2<<>>S,,,#'!">>">>>sUA0AA0$AAA A0AA0AA0A-!A$ "A-)A0)rrrlr*rfreezerrrrrrforce_not_null force_nullrwherecK|j4d{}|j||||||||| | | | | |||||d{cdddd{S7@77 #1d{7swYyxYww)a&Copy 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)sourcerrrlr*rrrrrrrrrrrr)ru copy_to_table)r+r rrrrlr*rrrrrrrrrrrrr;s r$rzPool.copy_to_tables><<>>S**'#'-%!%+">>">>>sVA3AA3'AAA A3AA3AA3A0$A' %A0,A3)rrrlrc K|j4d{}|j||||||d{cdddd{S7477 #1d{7swYyxYww)aUCopy 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)recordsrrrlr)rucopy_records_to_table)r+r rrrrlrr;s r$rzPool.copy_records_to_tables[&<<>>S22' 3">>">>>rct||S)aTAcquire 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)r+rls r$ruz Pool.acquire4s."$00r%cKfd}jrtjdj|d{St j |d{S7(7w)NcKjjd{} |jd{}|_|S7&7#tt j f$rjj|wxYwwr=)rgetrurWrorprqr)rrsr+rls r$ _acquire_implz$Pool._acquire.._acquire_implNsr{{((B  jjl*&  )*w556  &&r* s5BABA A A B A 6BBzpool is closingrk)rrr) _check_initrr|)r+rlrs`` r$_acquirez Pool._acquireMsk  ==++,=> >  ?&( (22 2)2s$AA5A1 #A5,A3-A53A5cKt|tus|jj|ur%t j dj ||jy|j|jj|j}| |j}tj|j|d{S7w)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 poolrN)rr7r8rOrr)r*r(r _on_releaserWrpshieldr)r+rrlrs r$rz Pool.releasees  $7 7""((4++>>Df)?E?+, , ?? "   ##%    ?kkG ^^BJJw$78888sCC C CcK|jry|jd|_d} |jj d|j }|j Dcgc]}|j}}tj|d{|j Dcgc]}|j}}tj|d{ ||jd|_d|_ycc}w7lcc}w72#ttjf$r|jwxYw#||jd|_d|_wxYww)aAttempt 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)rrrrPr_warn_on_long_closerrrprrnrorqrr)r+warning_callbackr release_coros close_coross r$rnz Pool.closesE <<    "#zz44D,, . 48==B3@R&&(= B..-0 0 0&*]]4%2r ] 4..+. . . + '')DL!DM!B 04 .7112  NN     + '')DL!DMsd'E4DC45D C9 DC;6D DD!E4D;D+D--D00"EEc.tjdy)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().)loggerwarningrIs r$r&zPool._warn_on_long_closes' (r%c|jry|j|jD]}|jd|_y)z&Terminate all connections in the pool.NT)rrrrr+rs r$rzPool.terminates6 <<  --B LLN  r%c6K|xjdz c_yw)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 rN)rXrIs r$expire_connectionszPool.expire_connectionss Asc|js6|jrtjdtjd|jrtjdy)Nzipool is being initialized, but not yet ready: likely there is a race between creating a pool and using itzpool is not initializedr)rrrr)rrIs r$rzPool._check_inits^  !! //  ++,EF F <<++,<= = r%ct|jD])}|j|jj+yr=)rr(_drop_local_statement_cacher.s r$_drop_statement_cachezPool._drop_statement_caches*--Bww"335 r%ct|jD])}|j|jj+yr=)rr(_drop_local_type_cacher.s r$_drop_type_cachezPool._drop_type_caches*--Bww"..0 r%c>|jjSr=)r __await__rIs r$r9zPool.__await__s""$..00r%cBK|jd{|S7wr=)rrIs r$ __aenter__zPool.__aenter__s"!!###  $s c@K|jd{y7wr=)rn)r+excs r$ __aexit__zPool.__aexit__sjjls r=))r1r2r3rrKr?rrrrrrrrrfstrfloatrrlistrrrrr rrrrur rrnr&rr0rr4r7r9r;r>rLr%r$rr4sIO-b% 5B-<L.0&P?C D3 D Ds DGK I I I"   .34T >48d"7;*  !+d  (^  )3t:"&122048$9L+"Z(  >6 1 1r%rc(eZdZdZdZdZdZdZy)r)rlrrrZc<||_||_d|_d|_y)NF)rZrlrr)r+rZrls r$r?zPoolAcquireContext.__init__s   r%cK|j |jrtjd|jj |j d{|_|jS7w)Nz a connection is already acquired)rrrr)rZr rlrIs r$r;zPoolAcquireContext.__aenter__sU ?? &$))++,NO O $ 2 24<< @@AsAA0A.A0cKd|_|j}d|_|jj|d{y7wNT)rrrZr)r+r=r;s r$r>zPoolAcquireContext.__aexit__s5 ooii$$$s9AAAcvd|_|jj|jj SrF)rrZr rlr9rIs r$r9zPoolAcquireContext.__await__ s+ yy!!$,,/99;;r%N)r1r2r3rKr?r;r>r9rLr%r$rrs9I  % ` 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. ) rrrrr[rrir\rrr)r) rrrr[rrir\rrrrrrs r$ create_poolrJsE~   )!  )I   r%r=)rprrloggingrzrrrrr getLoggerr1r+rr _ConnectionProxyr7r:rrrrrJrLr%r$rOs    8 $&d&RO*55$;#OBO+O+d| | ~<<6m!16!+!6!6%__mr%