i ddlmZddlZddlmZmZddlZddlZddlZddl Z ddl m Z ddl m Z mZmZddlZddlmZddlmZdd lmZdd lmZejeZGd d eZGd dejedZGddZGddZGddZddddddddddej ej!d dZ"dS)) annotationsN) AwaitableCallable) TracebackType)AnyOptionalType)compat connection) exceptions)protocolc>eZdZdddfd ZeddZxZS)PoolConnectionProxyMetaF)wrapnamestrbasestuple[Type[Any], ...]dctdict[str, Any]rboolreturnc|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__) mclsrrrrattrnamemeth iscoroutinewrapper __class__s F/var/www/html/gemini/venv/lib/python3.11/site-packages/asyncpg/pool.pyr)zPoolConnectionProxyMeta.__new__s  ? 566 ( (&&s++x3z4h??)$//%9$?? 66xMM#27DAA 'H ##!+!6!>IwwtT5#666 meth_namer-Callable[..., Any]c@dfd }|rtj||S)Nselfrargskwargsrc|j'tjdt |jj}||jg|Ri|S)NzJcannot call Connection.{}(): connection has been released back to the pool)_conrInterfaceErrorformatr!r/)r5r6r7r,r2s r0call_con_methodzHPoolConnectionProxyMeta._wrap_connection_method..call_con_method=sry  /DDJF!E#E#$$$ 49. ::D4 3D333F33 3r1)r5rr6rr7rrr)r markcoroutinefunction)r2r-r<s` r0r%z/PoolConnectionProxyMeta._wrap_connection_method9sB 4 4 4 4 4 4  :  ( 9 9 9r1) rrrrrrrrrr)r2rr-rrr3)__name__ __module__ __qualname__r) staticmethodr% __classcell__)r/s@r0rrsl 777777776\r1rc2eZdZdZddZdd ZddZddZdS)PoolConnectionProxy)r9_holderholderPoolConnectionHolderconconnection.ConnectionrNonecL||_||_||dSN)r9rE _set_proxy)r5rFrHs r0__init__zPoolConnectionProxy.__init__Ts*   tr1attrrrc,t|j|SrL)r!r9)r5rOs r0 __getattr__zPoolConnectionProxy.__getattr__[sty$'''r1Optional[connection.Connection]c`|jdS|jdc}|_|d|SrL)r9rM)r5rHs r0_detachzPoolConnectionProxy._detach_s5 9  FDTY t r1c|j.d|jjt |Sd|jj|jt |S)Nz <{classname} [released] {id:#x}>) classnameidz<{classname} {con!r} {id:#x}>)rVrHrW)r9r;r/r>rWr5s r0__repr__zPoolConnectionProxy.__repr__gsp 9 5<<.1bhh=@@ @399.1tyRXX:OO Or1N)rFrGrHrIrrJ)rOrrr)rrR)rr)r>r?r@ __slots__rNrQrTrYr1r0rDrDNsq$I((((OOOOOOr1rDT) metaclassrceZdZdZdd Zdd ZddZd dZd!dZd"dZ d dZ d dZ d dZ d dZ d dZd dZd dZd dZdS)#rG) r9_pool_loop_proxy _max_queries_setup_max_inactive_time_in_use_inactive_callback_timeout _generationpool'Pool' max_queriesfloatsetup:Optional[Callable[[PoolConnectionProxy], Awaitable[None]]]max_inactive_timerrJc||_d|_d|_||_||_||_d|_d|_d|_d|_ dSrL) r^r9r`rarcrbrerdrfrg)r5rhrjrlrns r0rNzPoolConnectionHolder.__init__xsT 59 59 '"3 6:15 )- *.r1rcH|jduo|j SrL)r9 is_closedrXs r0 is_connectedz!PoolConnectionHolder.is_connecteds%y$BTY-@-@-B-B)BBr1c|j SrLrdrXs r0is_idlezPoolConnectionHolder.is_idles <r1cK|jtjd|jd{V|_|jj|_||dS)NzMPoolConnectionHolder.connect() called while another connection already exists)r9rInternalClientErrorr^_get_new_connectionrg_maybe_cancel_inactive_callback_setup_inactive_callbackrXs r0connectzPoolConnectionHolder.connects 9 0,-- -*88:::::::: :1 ,,... %%'''''r1rDcK|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)r9rqr{rgr^r_ create_taskcloserfryrDr`rb ExceptionasyncioCancelledError create_futurerd)r5proxyexs r0acquirezPoolConnectionHolder.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  Er~Optional[float]cK|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 holderr})rdrrwr9rqrf _protocol queries_countrarrgr^_is_cancellingtime monotonicr wait_for_wait_for_cancellation_resetr~resetrrr terminate_releaserz)r5r~budgetstartedrs r0releasezPoolConnectionHolder.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{VdSrLrtrXs r0wait_until_releasedz(PoolConnectionHolder.wait_until_releaseds3 <  F,         r1cZK|j!|jd{VdSdSrL)r9rrXs r0rzPoolConnectionHolder.closesB 9 )//## # # # # # # # # # ! r1cJ|j|jdSdSrL)r9rrXs r0rzPoolConnectionHolder.terminates. 9  I   ! ! ! ! ! ! r1c|jtjd|jr1|jj|j|j|_dSdS)Nz/pool connection inactivity timer already exists)rerrwrcr^r_ call_later_deactivate_inactive_connectionrXs r0rzz-PoolConnectionHolder._setup_inactive_callbacksp  " .0ACC C  " O&*j&6&A&A')M'O'OD # # # O Or1cX|j"|jd|_dSdSrL)recancelrXs r0ryz4PoolConnectionHolder._maybe_cancel_inactive_callbacks6  " .  # * * , , ,&*D # # # / .r1c|jtjd|j/|j|dSdS)Nz/attempting to deactivate an acquired connection)rdrrwr9r_release_on_closerXs r0rz4PoolConnectionHolder._deactivate_inactive_connection"sg < #0ACC C 9  I   ! ! !  " " $ $ $ $ $ ! r1cd||d|_dSrL)ryrr9rXs r0rz&PoolConnectionHolder._release_on_close0s, ,,...  r1c|jdS|js|jdd|_|j |jd|_|jj|dS)zRelease this connection holder.N)rddone set_resultr`rTr^_queue put_nowaitrXs r0rzPoolConnectionHolder._release5s <  F|  "" * L # #D ) ) )  ; " K   ! ! !DK $$T*****r1N) rhrirjrkrlrmrnrkrrJ)rr)rrJ)rrD)r~rrrJ)r>r?r@rZrNrrrur{rrrrrrzryrrrr[r1r0rGrGps= I ////*CCCC     ( ( ( (####J=(=(=(=(~ $$$$ """" OOOO++++ % % % % ++++++r1rGceZdZdZdZddddddZdZdZdZd Z d Z d Z d Z d5d Z dZddd6dZddd7dZdddd8dZddddZddddZddddZddddddddddddd d!Zddddddddddd" d#Zddddddddddddddddd$d%Zddddd&d'Zddd(Zd)Zddd*Zd+Zd,Zd-Zd.Zd/Z d0Z!d1Z"d2Z#d3Z$d4Z%dS)9PoolaA 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`. )rr__minsize_maxsize_init_connectr _connect_args_connect_kwargs_holders _initialized _initializing_closing_closed_connection_class _record_classrgrbra!_max_inactive_connection_lifetimeN)r{rlinitrc 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)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_loopr_ ValueError issubclassr r TypeErrorr;rRecordrrrrrrrrrrrgr{rrrrbrrrar)r5min_sizemax_sizerj max_inactive_connection_lifetimer{rlrrloopconnection_class record_class connect_argsconnect_kwargss r0rNz Pool.__init__\s  |  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)rjrnrlr )r LifoQueuerrrangerGrarrbrappendrrr{ enumeratereversedgather)r5rchfirst_ch connect_tasksis r0rzPool._initializesx' >>> t}%% ' 'A% -"&"Hk ###B M  $ $ $ K " "2 & & & & = 5}R(H""$$ $ $ $ $ $ $ $}q  " &x crc0B'C'CDD77EArDMA---!((6666nm4444444444' 5 5! r1c|jp|jS)z_Return ``True`` if the pool is closing or is closed. .. versionadded:: 0.28.0 )rrrXs r0 is_closingzPool.is_closings |,t},r1c>td|jDS)zaReturn the current number of connections in this pool. .. versionadded:: 0.25.0 c3>K|]}|VdSrL)rr.0hs r0 z Pool.get_size..s,;;1>>##;;;;;;r1sumrrXs r0get_sizez Pool.get_sizes# ;;T];;;;;;r1c|jS)zaReturn the minimum number of connections in this pool. .. versionadded:: 0.25.0 )rrXs r0 get_min_sizezPool.get_min_size }r1c|jS)ziReturn the maximum allowed number of connections in this pool. .. versionadded:: 0.25.0 )rrXs r0 get_max_sizezPool.get_max_sizerr1c>td|jDS)zfReturn the current number of idle connections in this pool. .. versionadded:: 0.25.0 c3fK|],}|o|V-dSrL)rrrurs r0rz%Pool.get_idle_size..s9KK1>>##3 KKKKKKr1rrXs r0 get_idle_sizezPool.get_idle_sizes# KKT]KKKKKKr1c $|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)r5dsnrs r0set_connect_argszPool.set_connect_argss*"U-r1c*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 '')rrr_rrr isinstancer?r>typerr:rrrrr)r5rHgoodgood_nbadbad_nrs r0rxzPool._get_new_connections!DM  !3+   "         #t566 )D99$-99Fs))C~++ >::CL::+111(-111  : ! jjoo%%%%%%%%w56     ))++%%%%%%%H"HHHH  s*6CD)DD DD  Dr}queryrr~rrcK|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 Nr~)rexecute)r5rr~r6rHs r0rz Pool.executeAs'<<>> 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 Nr})r executemany)r5rr6r~rHs r0rzPool.executemanyRs <<>> 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 AAr~rlistcK|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)rfetchr5rr~rr6rHs r0rz Pool.fetches"<<>>       S" )                               A AArcolumnr~cK|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 )rfetchval)r5rr r~r6rHs r0rz Pool.fetchval|s<<>> > > > > > > >S%>>>%+W>>>>>>>>> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > >r cK|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)rfetchrowr s r0rz Pool.fetchrows"<<>>       S% )                               r cK|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)r fetchmany)r5rr6r~rrHs r0rzPool.fetchmanys<<>>       StW<'                              sA AA) columns schema_namer~r;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) outputrrr~r;rrrrrrrr)rcopy_from_table)r5 table_namerrrr~r;rrrrrrrrrHs r0rzPool.copy_from_tables16<<>>       S,,'#'!-                              s)A A#&A#) r~r;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) rr~r;rrrrrrrr)rcopy_from_query)r5rrr~r;rrrrrrrrr6rHs r0r"zPool.copy_from_querys>2<<>>       S,,#'!                              !A AA)rrr~r;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)sourcerrr~r;rr$rrrrrrr%r&rr')r copy_to_table)r5r r)rrr~r;rr$rrrrrrr%r&rr'rHs r0r*zPool.copy_to_tables=><<>>       S**'#'-%!%+                              s-A A'*A')rrr~r'c 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)recordsrrr~r')rcopy_records_to_table)r5r r,rrr~r'rHs r0r-zPool.copy_records_to_table7s&<<>>       S22' 3                              r#c"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)r5r~s r0rz Pool.acquireTs."$000r1cKfd}jrtjd|d{VSt j|d{VS)NcKjd{V} |d{V}|_|S#tt jf$rj|wxYwrL)rgetrrfrrrr)rrr5r~s r0 _acquire_implz$Pool._acquire.._acquire_implns{((((((((B  jjll******&  w56    &&r*** s A2A9zpool is closingr})rrr: _check_initr r)r5r~r3s`` r0_acquirez Pool._acquirems       = ?+,=>> >  ?&(((((( ( 222222222 2r1cKt|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 poolr N)rrDrEr^rr:r;r9r4 _on_releaserfrshieldr)r5r r~rs r0rz Pool.releases   $7 7 7"(44+>>Df)?E?+?+,, , ? " F  ##%%%   ?kG ^BJJw$7$7888888888r1c(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|]}|Sr[)rrrs r0 zPool.close..s7BBB-/&&((BBBr1c6g|]}|Sr[rr<s r0r=zPool.close..s-444! 444r1F) rr4rr_r_warn_on_long_closerrrrrrr)r5warning_callback release_coros close_coross r0rz 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().)loggerwarningrXs r0r@zPool._warn_on_long_closes'' ( ( ( ( (r1c|jrdS||jD]}|d|_dS)z&Terminate all connections in the pool.NT)rr4rrr5rs r0rzPool.terminatesN <  F -  B LLNNNN r1c*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 r N)rgrXs r0expire_connectionszPool.expire_connectionss" Ar1c|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:rrXs r0r4zPool._check_initsm  G!  /   +,EFF F < >+,<== = > >r1cZ|jD]"}|j|j#dSrL)rr9_drop_local_statement_cacherHs r0_drop_statement_cachezPool._drop_statement_caches:- 6 6Bw"33555 6 6r1cZ|jD]"}|j|j#dSrL)rr9_drop_local_type_cacherHs r0_drop_type_cachezPool._drop_type_caches:- 1 1Bw"..000 1 1r1cN|SrL)r __await__rXs r0rSzPool.__await__s ""$$..000r1c>K|d{V|SrL)rrXs r0 __aenter__zPool.__aenter__ s/!!######### r1c>K|d{VdSrLr?)r5excs r0 __aexit__zPool.__aexit__s,jjllr1rL)rrr~rrr)rrr~r)rr)&r>r?r@rrZrNrrrrrrrrrxrrrrrrrr"r*r-rr5rrr@rrJr4rNrQrSrUrXr[r1r0rrIsIO-O-O-O-O-b%%% 555B---<<<LLL....0&&&X"& DDDDDD,"& IIIIII. .34T > > > > >48d"7;*  !+++++d  (((((^  )33333t:"&111112222048$9$9$9$9$9L+"+"+"Z(((  > > >666 111 111r1rc6eZdZdZddZd Z dddZdZd S)r/)r~r rrhrhrr~rrrJc>||_||_d|_d|_dS)NF)rhr~r r)r5rhr~s r0rNzPoolAcquireContext.__init__s"   r1cK|j|jrtjd|j|jd{V|_|jS)Nz a connection is already acquired)r rrr:rhr5r~rXs r0rUzPoolAcquireContext.__aenter__sZ ? &$) &+,NOO O $ 2 24< @ @@@@@@@r1Nexc_typeOptional[Type[BaseException]]exc_valOptional[BaseException]exc_tbOptional[TracebackType]ctKd|_|j}d|_|j|d{VdSNT)rr rhr)r5r\r^r`rHs r0rXzPoolAcquireContext.__aexit__#sK  oi$$$$$$$$$$$r1crd|_|j|jSrc)rrhr5r~rSrXs r0rSzPoolAcquireContext.__await__.s- y!!$,//99;;;r1)rhrr~rrrJ)NNN)r\r]r^r_r`rarrJ)r>r?r@rZrNrUrXrSr[r1r0r/r/so9I 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. ) rrrrrjrr{rlrrr)r) rrrrjrr{rlrrrrrrs r0 create_poolrg3sO~   )!  )I     r1rL)# __future__rrcollections.abcrrr&r"loggingrtypesrtypingrrr rr r rr getLoggerr>rErr_ConnectionProxyrDrGrr/rrrgr[r1r0rpsD#"""""//////// &&&&&&&&&&  8 $ $/////d///dOOOOO*5$;#OOOODV+V+V+V+V+V+V+V+rG G G G G G G G T<<<<<<<<@m!16!+!6%_mmmmmmmr1