+
    i4                       ^ RI Ht ^ RIt^ RIHt ^ RIHt ^ RIHt ^ RIHt ^RIHt ^RIH	t	 ^R	IH
t
 ^R
IHt ^RIHt ^RIHt ]P                  '       d   ^RIHt ^RIHt  ! R R]P(                  ]	,          4      tR# )    )annotationsN)Any)Optional)Type)Union)ConnectionPoolEntry)Pool)PoolProxiedConnection)PoolResetState)event)util)Engine)DBAPIConnectionc                  $   ] tR t^tRtRt]t]P                  ! R4      ]
R R l4       4       t]
R R l4       tR R	 ltR
 R ltR R ltR R lt]P$                  ! RRR.R 4      R R l4       tR R ltR R ltR R ltR R ltR R ltR tR!# )"
PoolEventsaX  Available events for :class:`_pool.Pool`.

The methods here define the name of an event as well
as the names of members that are passed to listener
functions.

e.g.::

    from sqlalchemy import event


    def my_on_checkout(dbapi_conn, connection_rec, connection_proxy):
        "handle an on checkout event"


    event.listen(Pool, "checkout", my_on_checkout)

In addition to accepting the :class:`_pool.Pool` class and
:class:`_pool.Pool` instances, :class:`_events.PoolEvents` also accepts
:class:`_engine.Engine` objects and the :class:`_engine.Engine` class as
targets, which will be resolved to the ``.pool`` attribute of the
given engine or the :class:`_pool.Pool` class::

    engine = create_engine("postgresql+psycopg2://scott:tiger@localhost/test")

    # will associate with engine.pool
    event.listen(engine, "checkout", my_on_checkout)

SomeEngineOrPoolzsqlalchemy.enginec               $    V ^8  d   QhRRRRRR/# )   targetz-Union[Pool, Type[Pool], Engine, Type[Engine]]
identifierstrreturnz!Optional[Union[Pool, Type[Pool]]] )formats   "C:\Users\petid\OneDrive\Desktop\Maestro\MAESTRO CLAUDE\MAESTRO\maestro-backend\venv\Lib\site-packages\sqlalchemy\pool\events.py__annotate__PoolEvents.__annotate__?   s(      =  
+	    c                	   \         P                  '       g%   \        P                  P                  P
                  p\        V\        4      '       d3   \        VX4      '       d   \        # \        V\        4      '       g   Q hV# \        VX4      '       d   VP                  # \        V\        4      '       d   V# \        VR 4      '       d   VP                  4        R# R# )_no_async_engine_eventsN)typingTYPE_CHECKINGr   	preloadedenginer   
isinstancetype
issubclassr	   poolhasattrr    )clsr   r   r   s   &&& r   _accept_withPoolEvents._accept_with=   s     ###^^**11Ffd##&&))!&$////'';;%%MV677**,r   c               $    V ^8  d   QhRRRRRR/# )r   	event_keyzevent._EventKey[Pool]kwr   r   Noner   )r   s   "r   r   r   W   s(     	$ 	$(	$ 	$ 
		$r   c                	z    VP                   pVP                  R VP                  4       VP                  ! R/ VB  R# )asyncioNr   )dispatch_target
setdefault_is_asynciobase_listen)r*   r.   r/   r   s   &&, r   _listenPoolEvents._listenV   s4     **
i!3!34##r   c               $    V ^8  d   QhRRRRRR/# r   dbapi_connectionr   connection_recordr   r   r0   r   )r   s   "r   r   r   b   s(      ) / 
	r   c                    R# )a  Called at the moment a particular DBAPI connection is first
created for a given :class:`_pool.Pool`.

This event allows one to capture the point directly after which
the DBAPI module-level ``.connect()`` method has been used in order
to produce a new DBAPI connection.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

Nr   selfr;   r<   s   &&&r   connectPoolEvents.connectb       r   c               $    V ^8  d   QhRRRRRR/# r:   r   )r   s   "r   r   r   v   s(      ) / 
	r   c                    R# )a  Called exactly once for the first time a DBAPI connection is
checked out from a particular :class:`_pool.Pool`.

The rationale for :meth:`_events.PoolEvents.first_connect`
is to determine
information about a particular series of database connections based
on the settings used for all connections.  Since a particular
:class:`_pool.Pool`
refers to a single "creator" function (which in terms
of a :class:`_engine.Engine`
refers to the URL and connection options used),
it is typically valid to make observations about a single connection
that can be safely assumed to be valid about all subsequent
connections, such as the database version, the server and client
encoding settings, collation settings, and many others.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

Nr   r>   s   &&&r   first_connectPoolEvents.first_connectv   rB   r   c               (    V ^8  d   QhRRRRRRRR/# )	r   r;   r   r<   r   connection_proxyr
   r   r0   r   )r   s   "r   r   r      s2      ) / 0	
 
r   c                    R# )a  Called when a connection is retrieved from the Pool.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

:param connection_proxy: the :class:`.PoolProxiedConnection` object
  which will proxy the public interface of the DBAPI connection for the
  lifespan of the checkout.

If you raise a :class:`~sqlalchemy.exc.DisconnectionError`, the current
connection will be disposed and a fresh connection retrieved.
Processing of all checkout listeners will abort and restart
using the new connection.

.. seealso:: :meth:`_events.ConnectionEvents.engine_connect`
   - a similar event
   which occurs upon creation of a new :class:`_engine.Connection`.

Nr   )r?   r;   r<   rH   s   &&&&r   checkoutPoolEvents.checkout   rB   r   c               $    V ^8  d   QhRRRRRR/# )r   r;   zOptional[DBAPIConnection]r<   r   r   r0   r   )r   s   "r   r   r      s(      3 / 
	r   c                    R# )a  Called when a connection returns to the pool.

Note that the connection may be closed, and may be None if the
connection has been invalidated.  ``checkin`` will not be called
for detached connections.  (They do not return to the pool.)

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

Nr   r>   s   &&&r   checkinPoolEvents.checkin   rB   r   z2.0r;   r<   c                	
    V V3# )Nr   )r;   r<   reset_states   &&&r   <lambda>PoolEvents.<lambda>   s    B
r   c               (    V ^8  d   QhRRRRRRRR/# )	r   r;   r   r<   r   rQ   r   r   r0   r   )r   s   "r   r   r      s2     6 6)6 /6 $	6
 
6r   c                    R# )a  Called before the "reset" action occurs for a pooled connection.

This event represents
when the ``rollback()`` method is called on the DBAPI connection
before it is returned to the pool or discarded.
A custom "reset" strategy may be implemented using this event hook,
which may also be combined with disabling the default "reset"
behavior using the :paramref:`_pool.Pool.reset_on_return` parameter.

The primary difference between the :meth:`_events.PoolEvents.reset` and
:meth:`_events.PoolEvents.checkin` events are that
:meth:`_events.PoolEvents.reset` is called not just for pooled
connections that are being returned to the pool, but also for
connections that were detached using the
:meth:`_engine.Connection.detach` method as well as asyncio connections
that are being discarded due to garbage collection taking place on
connections before the connection was checked in.

Note that the event **is not** invoked for connections that were
invalidated using :meth:`_engine.Connection.invalidate`.    These
events may be intercepted using the :meth:`.PoolEvents.soft_invalidate`
and :meth:`.PoolEvents.invalidate` event hooks, and all "connection
close" events may be intercepted using :meth:`.PoolEvents.close`.

The :meth:`_events.PoolEvents.reset` event is usually followed by the
:meth:`_events.PoolEvents.checkin` event, except in those
cases where the connection is discarded immediately after reset.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

:param reset_state: :class:`.PoolResetState` instance which provides
 information about the circumstances under which the connection
 is being reset.

 .. versionadded:: 2.0

.. seealso::

    :ref:`pool_reset_on_return`

    :meth:`_events.ConnectionEvents.rollback`

    :meth:`_events.ConnectionEvents.commit`

Nr   )r?   r;   r<   rQ   s   &&&&r   resetPoolEvents.reset   rB   r   c               (    V ^8  d   QhRRRRRRRR/# 	r   r;   r   r<   r   	exceptionzOptional[BaseException]r   r0   r   )r   s   "r   r   r     s2      ) / +	
 
r   c                    R# )a  Called when a DBAPI connection is to be "invalidated".

This event is called any time the
:meth:`.ConnectionPoolEntry.invalidate` method is invoked, either from
API usage or via "auto-invalidation", without the ``soft`` flag.

The event occurs before a final attempt to call ``.close()`` on the
connection occurs.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

:param exception: the exception object corresponding to the reason
 for this invalidation, if any.  May be ``None``.

.. seealso::

    :ref:`pool_connection_invalidation`

Nr   r?   r;   r<   rZ   s   &&&&r   
invalidatePoolEvents.invalidate  rB   r   c               (    V ^8  d   QhRRRRRRRR/# rY   r   )r   s   "r   r   r   !  s2      ) / +	
 
r   c                    R# )a  Called when a DBAPI connection is to be "soft invalidated".

This event is called any time the
:meth:`.ConnectionPoolEntry.invalidate`
method is invoked with the ``soft`` flag.

Soft invalidation refers to when the connection record that tracks
this connection will force a reconnect after the current connection
is checked in.   It does not actively close the dbapi_connection
at the point at which it is called.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

:param exception: the exception object corresponding to the reason
 for this invalidation, if any.  May be ``None``.

Nr   r\   s   &&&&r   soft_invalidatePoolEvents.soft_invalidate!  rB   r   c               $    V ^8  d   QhRRRRRR/# r:   r   )r   s   "r   r   r   =  s(      ) / 
	r   c                    R# )am  Called when a DBAPI connection is closed.

The event is emitted before the close occurs.

The close of a connection can fail; typically this is because
the connection is already closed.  If the close operation fails,
the connection is discarded.

The :meth:`.close` event corresponds to a connection that's still
associated with the pool. To intercept close events for detached
connections use :meth:`.close_detached`.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

Nr   r>   s   &&&r   closePoolEvents.close=  rB   r   c               $    V ^8  d   QhRRRRRR/# r:   r   )r   s   "r   r   r   V  s(      ) / 
	r   c                    R# )a~  Called when a DBAPI connection is "detached" from a pool.

This event is emitted after the detach occurs.  The connection
is no longer associated with the given connection record.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

:param connection_record: the :class:`.ConnectionPoolEntry` managing
 the DBAPI connection.

Nr   r>   s   &&&r   detachPoolEvents.detachV  rB   r   c                    V ^8  d   QhRRRR/# )r   r;   r   r   r0   r   )r   s   "r   r   r   h  s       4 r   c                    R# )al  Called when a detached DBAPI connection is closed.

The event is emitted before the close occurs.

The close of a connection can fail; typically this is because
the connection is already closed.  If the close operation fails,
the connection is discarded.

:param dbapi_connection: a DBAPI connection.
 The :attr:`.ConnectionPoolEntry.dbapi_connection` attribute.

Nr   )r?   r;   s   &&r   close_detachedPoolEvents.close_detachedh  rB   r   r   N)__name__
__module____qualname____firstlineno____doc___target_class_docr	   _dispatch_targetr   preload_moduleclassmethodr+   r7   r@   rE   rJ   rN   r   _legacy_signaturerV   r]   ra   re   ri   rm   __static_attributes__r   r   r   r   r      s    < +	,-  .. 	$ 	$(::& 	01	
66p<82$ r   r   )
__future__r   r!   r   r   r   r   baser   r	   r
   r    r   r   r"   r$   r   engine.interfacesr   Eventsr   r   r   r   <module>r      sT    #      %  '    	3Yd# Yr   