ۇehP RddlZddlZddlZddlZddlZddlZddlmZddlmZddlm Z ddlm Z ej e Z GddeZGd d ejed ZGd dZGddZGddZddddddddddeje jd dZdS)N)compat connection) exceptions)protocolc:eZdZddfd ZedZxZS)PoolConnectionProxyMetaF)wrapc|rttjD]}|ds||vrt tj|}t j|sKt j|}|||}tj ||}|||<d|vrtjj |d<t ||||S)N___doc__)dirr Connection startswithgetattrinspect isfunctioniscoroutinefunction_wrap_connection_method functoolsupdate_wrapperrsuper__new__) mclsnamebasesdctr attrnamemeth iscoroutinewrapper __class__s >/var/www/api/venv/lib/python3.11/site-packages/asyncpg/pool.pyrzPoolConnectionProxyMeta.__new__s  ? 566 ( (&&s++x3z4h??)$//%9$?? 66xMM#27DAA 'H ##!+!6!>IwwtT5#666c>fd}|rtj||S)Nc|j'tjdt |jj}||jg|Ri|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_method0sry  /DDJF!E#E#$$$ 49. ::D4 3D333F33 3r%)rmarkcoroutinefunction)r.r!r/s` r$rz/PoolConnectionProxyMeta._wrap_connection_method.s= 4 4 4 4 4  :  ( 9 9 9r%)__name__ __module__ __qualname__r staticmethodr __classcell__)r#s@r$r r s`057777777(\r%r cNeZdZdZdddejfdZdZdejfdZd Z d S) PoolConnectionProxy)r(_holderholderPoolConnectionHolderconcL||_||_||dSN)r(r8 _set_proxy)r+r9r;s r$__init__zPoolConnectionProxy.__init__Gs(   tr%c,t|j|Sr=)rr()r+attrs r$ __getattr__zPoolConnectionProxy.__getattr__Msty$'''r%returnc`|jdS|jdc}|_|d|Sr=)r(r>)r+r;s r$_detachzPoolConnectionProxy._detachQs5 9  FDTY t r%c|j.d|jjt |Sd|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__Ysp 9 5<<.1bhh=@@ @399.1tyRXX:OO Or%N) r1r2r3 __slots__rrr?rBrErJr%r$r7r7As$I5 + (((.OOOOOr%r7T) metaclassr cleZdZdZdZdZdZdZdefdZ dZ d Z d Z d Z d Zd ZdZdZdZdS)r:) r(_pool_loop_proxy _max_queries_setup_max_inactive_time_in_use_inactive_callback_timeout _generationc||_d|_d|_||_||_||_d|_d|_d|_d|_ dSr=) rOr(rQrRrTrSrVrUrWrX)r+pool max_queriessetupmax_inactive_times r$r?zPoolConnectionHolder.__init__jsR   '"3 "&  r%cH|jduo|j Sr=)r( is_closedrIs r$ is_connectedz!PoolConnectionHolder.is_connectedxs%y$BTY-@-@-B-B)BBr%c|j Sr=rUrIs r$is_idlezPoolConnectionHolder.is_idle{s <r%cK|jtjd|jd{V|_|jj|_||dS)NzMPoolConnectionHolder.connect() called while another connection already exists)r(rInternalClientErrorrO_get_new_connectionrX_maybe_cancel_inactive_callback_setup_inactive_callbackrIs r$connectzPoolConnectionHolder.connect~s 9 0,-- -*88:::::::: :1 ,,... %%'''''r%rCcK|j|jr"d|_|d{Vns|j|jjkr^|jj|j|jd|_|d{V| t||jx|_ }|j c | |d{VnF#ttjf$r-} |jd{V|#|xYwd}~wwxYw|jj|_|S)Ntimeout)r(r_rirXrOrP create_taskcloserWrgr7rQrS ExceptionasyncioCancelledError create_futurerU)r+proxyexs r$acquirezPoolConnectionHolder.acquires 9  3 3 5 5 DI,,..  !7 7 7 J  ( (  66 8 8 8DI,,..  ,,...1$ BBB e ; " kk%((((((((((w56     )//+++++++++H"HHHH z'5577  s*0D E#EE EE  EcK|jtjd|jrdSd|_|jjj|jkr#|j |d{VdS|j |j j kr#|j |d{VdS |}|jj retj}tj|jj|d{V||tj|z z}|j jtj|4d{V|jd{V|j |jd{Vdddd{Vn#1d{VswxYwYn!|j|d{Vn@#t*t,jf$r'} |j|#|xYwd}~wwxYw||dS)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.releases0 < 0+,, , 9     F 9  ,0A A A)//'/22 2 2 2 2 2 2 2 F  tz5 5 5)//'/22 2 2 2 2 2 2 2 F Fy"1133 9.**oI'>>@@%dn..88Fz ,!>&1177777777)**,,,,,,,,,*++DI666666666777777777777777777777777777ioofo555555555712     ##%%%b   %%'''''sP6B+G,!AF8&G,8 GG,G%G,,H)HH$H!!H$$H)c6K|jdS|jd{VdSr=rbrIs r$wait_until_releasedz(PoolConnectionHolder.wait_until_releaseds3 <  F,         r%cZK|j!|jd{VdSdSr=)r(rnrIs r$rnzPoolConnectionHolder.closesB 9 )//## # # # # # # # # # ! r%cJ|j|jdSdSr=)r(rrIs r$rzPoolConnectionHolder.terminates. 9  I   ! ! ! ! ! ! r%c|jtjd|jr1|jj|j|j|_dSdS)Nz/pool connection inactivity timer already exists)rVrrerTrOrP call_later_deactivate_inactive_connectionrIs r$rhz-PoolConnectionHolder._setup_inactive_callbacksp  " .0ACC C  " O&*j&6&A&A')M'O'OD # # # O Or%cX|j"|jd|_dSdSr=)rVcancelrIs r$rgz4PoolConnectionHolder._maybe_cancel_inactive_callbacks6  " .  # * * , , ,&*D # # # / .r%c|jtjd|j/|j|dSdS)Nz/attempting to deactivate an acquired connection)rUrrer(r_release_on_closerIs r$rz4PoolConnectionHolder._deactivate_inactive_connection sg < #0ACC C 9  I   ! ! !  " " $ $ $ $ $ ! r%cd||d|_dSr=)rgrr(rIs r$rz&PoolConnectionHolder._release_on_closes, ,,...  r%c|jdS|js|jdd|_|j |jd|_|jj|dS)zRelease this connection holder.N)rUdone set_resultrQrErO_queue put_nowaitrIs r$rzPoolConnectionHolder._release s <  F|  "" * L # #D ) ) )  ; " K   ! ! !DK $$T*****r%N)r1r2r3rKr?r`rcrir7rurrrnrrhrgrrrrLr%r$r:r:bs I    CCC    ( ( (#2####J=(=(=(~ $$$ """ OOO+++ % % % +++++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(dS)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 t| dkrtjdtd| t j} | |_|dkrtd|dkrtd||krtd|dkrtd |dkrtd t| tj s"td | t| tjs"td | ||_||_g|_d |_d |_d|_| |_| |_d |_d |_d|_||n tj|_| |_| |_||_||_||_ ||_!||_"dS)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 M0#q  2 2 2 2 <)++D q==KLL L a<<EGG G h  @AA A !  NOO O +a / /#$$ $*J,ABB I//5v6F/G/GII I,88 A++16,+?+?AA A!    !" !1)  #*#6J+,<== =! %""$$ $ $ $ $ $ $ $!&D  $D  "'D  $D  $ $ $ $s A44BcKtj|j|_t |jD]X}t ||j|j|j}|j ||j |Y|j r|j d}| d{V|j dkrg}tt|j ddD]<\}}||j dz krn(| | =tj|d{VdSdSdS)N)maxsize)r[r]r\r)rp LifoQueuerrranger:rRrrSrappendrrri enumeratereversedgather)r+r chfirst_ch connect_tasksis r$rzPool._initializesx' >>> t}%% ' 'A% -"&"Hk ###B M  $ $ $ K " "2 & & & & = 5}R(H""$$ $ $ $ $ $ $ $}q  " &x crc0B'C'CDD77EArDMA---!((6666nm4444444444' 5 5! r%c|jp|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|]}|VdSr=)r`.0hs r$ z Pool.get_size..s,;;1>>##;;;;;;r%sumrrIs 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 c3fK|],}|o|V-dSr=)r`rcrs r$rz%Pool.get_idle_size..s9KK1>>##3 KKKKKKr%rrIs r$ get_idle_sizezPool.get_idle_sizes# KKT]KKKKKKr%c $|g|_||_dS)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%c*K|j|j|j|j|jd|jd{V}t ||jsf|j}|jd|j}t|}|jdkr|j}n|jd|j}tj d|d|d|j ^ | |d{VnA#ttjf$r(} |d{V|#|xYwd}~wwxYw|S)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_connections!DM  !3+   "         #t566 )D99$-99Fs))C~++ >::CL::+111(-111  : ! jjoo%%%%%%%%w56     ))++%%%%%%%H"HHHH  s*6CD)DD DD  DrkqueryrlrCcK|4d{V}|j|g|Rd|id{Vcdddd{VS#1d{VswxYwYdS)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,s'<<>> D D D D D D DS$UCTCCC7CCCCCCCC D D D D D D D D D D D D D D D D D D D D D D D D D D D D D DsA AAcommandcK|4d{V}||||d{Vcdddd{VS#1d{VswxYwYdS)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.executemany8s<<>> I I I I I I IS$HHHHHHHH I I I I I I I I I I I I I I I I I I I I I I I I I I I I I IsA AArlrcK|4d{V}|j|g|R||dd{Vcdddd{VS#1d{VswxYwYdS)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" )                               A AArcolumnrlcK|4d{V}|j|g|R||dd{Vcdddd{VS#1d{VswxYwYdS)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\s<<>> > > > > > > >S%>>>%+W>>>>>>>>> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > >rcK|4d{V}|j|g|R||dd{Vcdddd{VS#1d{VswxYwYdS)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|4d{V}|||||d{Vcdddd{VS#1d{VswxYwYdS)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{s<<>>       StW<'                              sA AA) columns schema_namerlr*oids delimiternullheaderquoteescape force_quoteencodingc K|4d{V}|||||||||| | | | | |d{Vcdddd{VS#1d{VswxYwYdS)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_tables16<<>>       S,,'#'!-                              s)A A#&A#) rlr*rrrrrrrrc K|4d{V}|j|g| R|||||||| | | | d d{Vcdddd{VS#1d{VswxYwYdS)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_querys>2<<>>       S,,#'!                              !A AA)rrrlr*rfreezerrrrrrforce_not_null force_nullrwherecK|4d{V}|||||||||| | | | | |||||d{Vcdddd{VS#1d{VswxYwYdS)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**'#'-%!%+                              s-A A'*A')rrrlrc K|4d{V}|||||||d{Vcdddd{VS#1d{VswxYwYdS)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                              rc"t||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."$000r%cKfd}jrtjd|d{VSt j|d{VS)NcKjd{V} |d{V}|_|S#tt jf$rj|wxYwr=)rgetrurWrorprqr)rrsr+rls r$ _acquire_implz$Pool._acquire.._acquire_implNs{((((((((B  jjll******&  w56    &&r*** s A2A9zpool is closingrk)rrr) _check_initrr|)r+rlrs`` r$_acquirez Pool._acquireMs       = ?+,=>> >  ?&(((((( ( 222222222 2r%cKt|tus|jj|ur(t jd||jdS||j |j}||j }tj | |d{VS)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 7"(44+>>Df)?E?+?+,, , ? " F  ##%%%   ?kG ^BJJw$7$7888888888r%c(K|jrdS|d|_d} |jd|j}d|jD}tj|d{Vd|jD}tj|d{Vn/#ttj f$r| wxYw || d|_d|_dS#|| d|_d|_wxYw)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<c6g|]}|SrL)rrrs r$ zPool.close..s7BBB-/&&((BBBr%c6g|]}|SrLrnr(s r$r)zPool.close..s-444! 444r%F) rr rrPr_warn_on_long_closerrprrorqrr)r+warning_callback release_coros close_coross r$rnz Pool.closes} <  F   "#z44D, . . BB37=BBBM.-0 0 0 0 0 0 0 044%)]444K.+. . . . . . . . .712    NN      / + '')))DL!DMMM + '')))DL!DM ! ! ! !sA*BC+,CC++&Dc:tddS)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|jrdS||jD]}|d|_dS)z&Terminate all connections in the pool.NT)rr rrr+rs r$rzPool.terminatesN <  F -  B LLNNNN r%c*K|xjdz c_dS)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" Ar%c|js/|jrtjdtjd|jrtjddS)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$r zPool._check_initsm  G!  /   +,EFF F < >+,<== = > >r%cZ|jD]"}|j|j#dSr=)rr(_drop_local_statement_cacher4s r$_drop_statement_cachezPool._drop_statement_caches:- 6 6Bw"33555 6 6r%cZ|jD]"}|j|j#dSr=)rr(_drop_local_type_cacher4s r$_drop_type_cachezPool._drop_type_caches:- 1 1Bw"..000 1 1r%cN|Sr=)r __await__rIs r$r?zPool.__await__s ""$$..000r%c>K|d{V|Sr=)rrIs r$ __aenter__zPool.__aenter__s/!!######### r%c>K|d{VdSr=r+)r+excs r$ __aexit__zPool.__aexit__s,jjllr%r=))r1r2r3rrKr?rrrrrrrrrfstrfloatrrlistrrrrr rrrrur!rrnr,rr6r r:r=r?rArDrLr%r$rr4sIO-O-O-O-O-b%%% 555B---<<<LLL....0&&&P?C D D D3 D Ds D D D DGK I I I I I I I I"   .34T > > > > >48d"7;*  !+++++d  (((((^  )33333t:"&111112222048$9$9$9$9$9L+"+"+"Z(((  > > >666 111 111r%rc*eZdZdZdZdZdZdZdS)r)rlrrrZc>||_||_d|_d|_dS)NF)rZrlrr)r+rZrls r$r?zPoolAcquireContext.__init__s"   r%cK|j|jrtjd|j|jd{V|_|jS)Nz a connection is already acquired)rrrr)rZr!rlrIs r$rAzPoolAcquireContext.__aenter__sZ ? &$) &+,NOO O $ 2 24< @ @@@@@@@r%ctKd|_|j}d|_|j|d{VdSNT)rrrZr)r+rCr;s r$rDzPoolAcquireContext.__aexit__sI oi$$$$$$$$$$$r%crd|_|j|jSrL)rrZr!rlr?rIs r$r?zPoolAcquireContext.__await__ s- y!!$,//99;;;r%N)r1r2r3rKr?rArDr?rLr%r$rrsU9I  %%% <<<<` 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_poolrPsO~   )!  )I     r%r=)rprrloggingrzrrrrr getLoggerr1r1rr _ConnectionProxyr7r:rrrrrPrLr%r$rUs   8 $ $&&&&&d&&&ROOOOO*5$;#OOOOBO+O+O+O+O+O+O+O+d| | | | | | | | ~<<<<<<<<6m!16!+!6%_mmmmmmmr%