+
    i-                    |  a  0 t $ R t^ RIHt ^ RIt^ RI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 ^ RIHt ^ RIt^RIHt ^RIHt ]P,                  '       d   ^RIHt ^RIHt ]R]3,          t]]]]]3,          3,          t]]]]3,          t]! RRR7      t  ! R R4      t!]R(,          t"]PF                  ! ]$4      t%R]&R&    ]R]3,          t']PF                  ! ]$4      t(R]&R&    R R lt)R R lt*R  R! lt+R" R# lt,R$ R% lt- ! R& R']] ,          4      t.R# ))aJ  Provides managed registration services on behalf of :func:`.listen`
arguments.

By "managed registration", we mean that event listening functions and
other objects can be added to various collections in such a way that their
membership in all those collections can be revoked at once, based on
an equivalent :class:`._EventKey`.

)annotationsN)Any)Callable)cast)Deque)Dict)Generic)Iterable)Optional)Tuple)TypeVar)Union)exc)util)RefCollection)
dispatcher._ETEventTarget)boundc                  *    ] tR t^2t$ RtRtR]R&   RtR# )r   zrepresents an event target, that is, something we can listen on
either with that target as a class or as an instance.

Examples include:  Connection, Mapper, Table, Session,
InstrumentedAttribute, Engine, Pool, Dialect.

zdispatcher[Any]dispatch N)__name__
__module____qualname____firstlineno____doc__	__slots____annotations____static_attributes__r       ڂC:\Users\petid\OneDrive\Desktop\Maestro\MAESTRO CLAUDE\MAESTRO\maestro-backend\venv\Lib\site-packages\sqlalchemy\event\registry.pyr   r   2   s     Ir    weakref.ref[_ListenerFnType]z6Dict[_EventKeyTupleType, _RefCollectionToListenerType]_key_to_collectionz>Dict[weakref.ref[RefCollection[Any]], _ListenerToEventKeyType]_collection_to_keyc                    V ^8  d   QhRRRR/# )   refzweakref.ref[Any]returnNoner   )formats   "r!   __annotate__r+   g   s     , ,* ,t ,r    c                <   \         '       d   V \         9  d   R # \        RV 4      p \         P                  V 4      pVP                  4        FM  pV\        9   g   K  \        V,          pVP                  V 4       V'       d   K8  \        P                  V4       KO  	  R # )Nz'weakref.ref[RefCollection[EventTarget]])r$   r   popvaluesr#   )r'   listener_to_keykeydispatch_regs   &   r!   _collection_gcedr2   g   sw    ,>!>
8#
>C(,,S1O%%'$$-c2LS!<"&&s+ (r    c               $    V ^8  d   QhRRRRRR/# )r&   	event_key_EventKey[_ET]ownerRefCollection[_ET]r(   boolr   )r*   s   "r!   r+   r+   x   s$      &8	r    c                    V P                   p\        V,          pVP                  p\        P                  ! V P                  4      pWC9   d   R # WSV&   \
        V,          pW&V&   R# )FT)_keyr#   r'   weakref
_listen_fnr$   )r4   r6   r0   r1   	owner_ref
listen_refr/   s   &&     r!   _stored_in_collectionr?   x   sZ     ..C%c*L		IY112J ((3O"%Jr    c               $    V ^8  d   QhRRRRRR/# )r&   r4   r5   r6   r7   r(   r)   r   )r*   s   "r!   r+   r+      s$     . ..&8.	.r    c                *   V P                   p\        V,          p\        P                  ! V P                  4      pVP                  pVP                  VR 4       V'       g   \        V V\        9   d"   \        V,          pVP                  VR 4       R # R # N)r:   r#   r;   r'   r<   r-   r$   )r4   r6   r0   r1   r>   r=   r/   s   &&     r!   _removed_from_collectionrC      sy     ..C%c*LY112J		IY%s#&&,Y7
 	J- 'r    c               (    V ^8  d   QhRRRRRRRR/# )r&   newownerr7   oldownerelementsIterable[_ListenerFnType]r(   r)   r   )r*   s   "r!   r+   r+      s0     !. !. !. !. (!. 
	!.r    c                n   V'       g   R # VP                   pV P                   p\        V,          p\        V,          pV FN  p\        P                   ! V4      p WX,          p	 \        T	,          p
YJ9   d   Y,          T8X  g   Q hMYT&   YT&   KP  	  R #   \         d     Kb  i ; i  \         d     Kt  i ; irB   )r'   r$   r;   KeyErrorr#   )rE   rF   rG   oldowner_refnewowner_refold_listener_to_keynew_listener_to_key	listen_fnr>   r0   r1   s   &&&        r!   _stored_in_collection_multirP      s    
 <<L<<L,\:,\:	[[+
	%1C	-c2L '-;;;)3&*-J''   	 	  		s$   B"B%B"!B"%B43B4c               $    V ^8  d   QhRRRRRR/# )r&   r6   r7   rG   rH   r(   r)   r   )r*   s   "r!   r+   r+      s&     ( (('( 
(r    c                    V'       g   R # V P                   p\        V,          pV FQ  p\        P                   ! V4      pW5,          p\        V,          pVP	                  VR 4       V'       d   KJ  \        V KS  	  R # rB   )r'   r$   r;   r#   r-   )r6   rG   r=   r/   rO   r>   r0   r1   s   &&      r!   _clearrS      sd     		I(3O	[[+
))#.D)|"3' r    c                     ] tR t^t$ RtR(tR]R&   R]R&   R	]R&   R
]R&   R]R&   R]R&   R)R R llt]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*R R llt]R R  l4       tR! R" ltR# R$ ltR% R& ltR'tR# )+	_EventKeyz$Represent :func:`.listen` arguments.target
identifierfnfn_keydispatch_targetr   str_ListenerFnType_ListenerFnKeyTyper   Optional[_ListenerFnType]_fn_wrapNc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r&   rV   r   rW   r[   rX   r\   rZ   r   r_   r^   r   )r*   s   "r!   r+   _EventKey.__annotate__   s<     / // / 	/
 / ,/r    c                	   Wn         W n        W0n        \        V\        P
                  4      '       d1   \        VP                  4      \        VP                  4      3V n	        M\        V4      V n	        WPn
        W@n        R # rB   )rV   rW   rX   
isinstancetypes
MethodTypeid__func____self__rY   fn_wraprZ   )selfrV   rW   rX   rZ   r_   s   &&&&&&r!   __init___EventKey.__init__   sX     $b%**++R[[/2bkk?:DKR&DK.r    c                   V ^8  d   QhRR/# )r&   r(   _EventKeyTupleTyper   )r*   s   "r!   r+   ra     s     ? ?( ?r    c                	Z    \        V P                  4      V P                  V P                  3# rB   )rf   rV   rW   rY   rj   s   &r!   r:   _EventKey._key   s    4;;$++>>r    c                    V ^8  d   QhRRRR/# )r&   ri   r\   r(   r5   r   )r*   s   "r!   r+   ra     s     
 
O 
 
r    c                	    WP                   J d   V # \        V P                  V P                  V P                  V P
                  VR 7      # )r_   )r<   rU   rV   rW   rX   rZ   )rj   ri   s   &&r!   with_wrapper_EventKey.with_wrapper  s?    oo%K$$  r    c                    V ^8  d   QhRRRR/# )r&   rZ   r   r(   r5   r   )r*   s   "r!   r+   ra     s     
 
C 
N 
r    c                	    WP                   J d   V # \        V P                  V P                  V P                  VV P
                  R 7      # rt   )rZ   rU   rV   rW   rX   ri   )rj   rZ   s   &&r!   with_dispatch_target_EventKey.with_dispatch_target  s?    222K r    c               $    V ^8  d   QhRRRRRR/# )r&   argsr   kwr(   r)   r   )r*   s   "r!   r+   ra     s&     E EC Es Et Er    c                	   VP                  R R4      pVP                  RR4      pVP                  RR4      pV P                  V P                  V P                  rp\	        VP
                  V4      p	V	P                  W4      p
V P                  V
4      p \	        V P                  P
                  P                  V P                  4      p\        VR4      '       d   VP                  4        V'       g	   V'       dD   V P                  \        P                  ! V P                  VR7      4      P                  ! V/ VB  R# V P                  P
                  P                  ! V .VO5/ VB  R# )onceF_once_unless_exceptionnamed_sa_warn)retry_on_exceptionN)r-   rZ   rW   r<   getattrr   _adjust_fn_specru   _eventshasattrr   r   	only_oncelisten_listen)rj   r|   r}   r   once_unless_exceptionr   rV   rW   rX   dispatch_collectionadjusted_fnstub_functions   &*,         r!   r   _EventKey.listen  s7   vvfe$ "'? Gw&   OOOO  &foozB)99"D  -  ))114??
 =*--""$(OO8M f	 	" !	"   ))11$DDDr    c                   V ^8  d   QhRR/# )r&   r(   r)   r   )r*   s   "r!   r+   ra   <  s     B B Br    c           	     	   V P                   pV\        9  dB   \        P                  ! R V P                  : RV P
                  : RV P                  : R24      h\        P                  V4      pVP                  4        F?  w  r4V! 4       pV! 4       pVf   K  Vf   K  VP                  V P                  V4      4       KA  	  R# )zNo listeners found for event z /  N)r:   r#   r   InvalidRequestErrorrV   rW   rX   r-   itemsremoveru   )rj   r0   r1   collection_reflistener_ref
collectionlistener_fns   &      r!   r   _EventKey.remove<  s    ii(());;: 
 *--c2,8,>,>,@(N')J&.K%+*A!!$"3"3K"@A	 -Ar    c                   V ^8  d   QhRR/# )r&   r(   r8   r   )r*   s   "r!   r+   ra   M  s     / /$ /r    c                (    V P                   \        9   # )z6Return True if this event key is registered to listen.)r:   r#   rp   s   &r!   contains_EventKey.containsM  s    yy...r    c               0    V ^8  d   QhRRRRRRRRRRRR	/# )
r&   	propagater8   insertr   retvalzOptional[bool]asyncior(   r)   r   )r*   s   "r!   r+   ra   Q  sF     / // / 	/
 / / 
/r    c                	   V P                   V P                  rv\        VP                  V4      pVP	                  VP                  4      p	V'       d   V	P                  4        V'       d   V	P                  W4       R # V	P                  W4       R # rB   )rZ   rW   r   r   
for_modify_set_asyncior   append)
rj   r   r   r   r   r   rV   rW   r   r   s
   &&&&&&    r!   base_listen_EventKey.base_listenQ  sh     "114??
%foozB(33FOOD
##%d.d.r    c                   V ^8  d   QhRR/# )r&   r(   r\   r   )r*   s   "r!   r+   ra   g  s     ' 'O 'r    c                	B    V P                   ;'       g    V P                  # rB   )ri   rX   rp   s   &r!   r<   _EventKey._listen_fnf  s    ||&&tww&r    c               $    V ^8  d   QhRRRRRR/# r&   r6   r7   list_Deque[_ListenerFnType]r(   r8   r   )r*   s   "r!   r+   ra   j  (     	 	!	 &	 
		r    c                	b    \        W4      '       d   VP                  V P                  4       R # R# TF)r?   r   r<   rj   r6   r   s   &&&r!   append_to_list_EventKey.append_to_listj  s%    
 !--LL)r    c               $    V ^8  d   QhRRRRRR/# )r&   r6   r7   r   r   r(   r)   r   )r*   s   "r!   r+   ra   u  s(     & &!& && 
	&r    c                	R    \        W4       VP                  V P                  4       R # rB   )rC   r   r<   r   s   &&&r!   remove_from_list_EventKey.remove_from_listu  s    
 	!-T__%r    c               $    V ^8  d   QhRRRRRR/# r   r   )r*   s   "r!   r+   ra   }  r   r    c                	b    \        W4      '       d   VP                  V P                  4       R # R# r   )r?   
appendleftr<   r   s   &&&r!   prepend_to_list_EventKey.prepend_to_list}  s'    
 !--T__-r    )rZ   rX   rY   ri   rW   rV   )rV   rW   rX   rY   ri   rZ   rB   )FFFNF)r   r   r   r   r   r   r   rk   propertyr:   ru   ry   r   r   r   r   r<   r   r   r   r   r   r    r!   rU   rU      s    .I KO''/$ ? ?

E@B"//* ' '	&	 	r    rU   )zweakref.ref[RefCollection[Any]]r"   )/__conditional_annotations__r   
__future__r   collectionsrd   typingr   r   r   r   r   r   r	   r
   r   r   r   r;    r   r   TYPE_CHECKINGattrr   baser   r\   intr]   r[   rn   r   r   _RefCollectionToListenerTypedefaultdictdictr#   r   _ListenerToEventKeyTyper$   r2   r?   rC   rP   rS   rU   )r   s   @r!   <module>r      sB   #                 	# 38$3c3h/0 3%778  e=)   $$   D! J 	 "  D!   "	,"*..!.H(&k kr    