Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
registry.cpython-313.pyc76 linesDownload Raw Back to __pycache__
1�

2��j-��^�%SrSSKJr SSKrSSKrSSKrSSKJr SSKJr SSKJr SSKJ	r	 SSKJ3r4 SS	KJr SS5KJr SSKJ
r
 SSKJr SS
KJr SSKJr SSKrSSKJr SSKJr \R*(aSSKJr SSKJr \S\4r\\\\\44r\\\\4r\"SSS9r"SS5r \6Sr!\RD"\#5r$S\%S'\7S\4r&\RD"\#5r'S\%S'S'S jr(S(S!jr)S)S"jr*S*S#jr+S+S$jr,"S%S&\\5r-g),aJProvides managed registration services on behalf of :func:`.listen`8arguments.9 10By "managed registration", we mean that event listening functions and11other objects can be added to various collections in such a way that their12membership in all those collections can be revoked at once, based on13an equivalent :class:`._EventKey`.14 15�)�annotationsN)�Any)�Callable)�cast)�Deque)�Dict)�Generic)�Iterable)�Optional)�Tuple)�TypeVar)�Union�)�exc)�util�)�
RefCollection)�16dispatcher.�_ET�EventTarget)�boundc�(�\rSrSr%SrSrS\S'Srg)r�2z�represents an event target, that is, something we can listen on17either with that target as a class or as an instance.18 19Examples include:  Connection, Mapper, Table, Session,20InstrumentedAttribute, Engine, Pool, Dialect.21 22�zdispatcher[Any]�dispatchN)�__name__�23__module__�__qualname__�__firstlineno__�__doc__�	__slots__�__annotations__�__static_attributes__r��_D:\code\apps\devtools\python\user_packages\Python313\site-packages\sqlalchemy/event/registry.pyrr2s����I��r$)zweakref.ref[RefCollection[Any]]�weakref.ref[_ListenerFnType]z6Dict[_EventKeyTupleType, _RefCollectionToListenerType]�_key_to_collectionr&z>Dict[weakref.ref[RefCollection[Any]], _ListenerToEventKeyType]�_collection_to_keyc�(�[(a24U[;ag[SU5n[RU5nUR5HGnU[;dM[UnURU5 U(aM2[RU5 MI g)Nz'weakref.ref[RefCollection[EventTarget]])r(r�pop�valuesr')�ref�listener_to_key�key�dispatch_regs    r%�_collection_gcedr0gsw�����,>�!>��25�8�#�26>�C�(�,�,�S�1�O��%�%�'���$�$�-�c�2�L����S�!��<�"�&�&�s�+�
(r$c��URn[UnURn[R"UR5nXC;agXSU'[27UnX&U'g)NFT)�_keyr'r,�weakref�28_listen_fnr()�	event_key�ownerr.r/�	owner_ref�29listen_refr-s       r%�_stored_in_collectionr9xsZ���.�.�C�%�c�*�L��	�	�I����Y�1�1�2�J�� ��(���(��3�O�"%�J��r$c��URn[Un[R"UR5nURnURUS5 U(d[U	U[;a[UnURUS5 gg�N)r2r'r3r,r4r*r()r5r6r.r/r8r7r-s       r%�_removed_from_collectionr<�sy���.�.�C�%�c�*�L����Y�1�1�2�J��	�	�I����Y��%���s�#��&�&�,�Y�7��30	���J��-�
'r$c�8�U(dgURnURn[Un[UnUH@n[R"U5nXXn	[U	n31XJ;aX�U:XdeOX�U'X�U'MB g![a MRf=f![a Mcf=fr;)r,r(r3�KeyErrorr')�newowner�oldowner�elements�oldowner_ref�newowner_ref�old_listener_to_key�new_listener_to_key�	listen_fnr8r.r/s           r%�_stored_in_collection_multirG�s���32���<�<�L��<�<�L�,�\�:��,�\�:���	��[�[��+�33�	�%�1�C�	�-�c�2�L��'��-��;�;�;�)3��&�*-�J�'�'���	�
�	���	��	�s$�A:�	B�:34B�B�35B�Bc���U(dgURn[UnUHHn[R"U5nX5n[UnUR	US5 U(aMA[U	MJ gr;)r,r(r3r'r*)r6rAr7r-rFr8r.r/s        r%�_clearrI�sd�����	�	�I�(��3�O��	��[�[��+�36��)��)�#�.������D�)��|�"�3�'�r$c�F�\rSrSr%SrSrS\S'S\S'S\S	'S37\S'S\S
'S\S'SSSjjr\S Sj5r	S!Sjr38S"SjrS#SjrS$Sjr
S%SjrS&S'Sjjr\S(Sj5rS)SjrS*SjrS)SjrSrg)+�	_EventKey��z$Represent :func:`.listen` arguments.)�target�39identifier�fn�fn_key�fn_wrap�dispatch_targetrrM�strrN�_ListenerFnTyperO�_ListenerFnKeyTyperPrrR�Optional[_ListenerFnType]�_fn_wrapNc���XlX lX0l[U[R405(a0[
UR5[
UR54Ul	O[
U5Ul	XPl41X@lgr;)rMrNrO�42isinstance�types�43MethodType�id�__func__�__self__rPrQrR)�selfrMrNrOrRrWs      r%�__init__�_EventKey.__init__�sX����$�����b�%�*�*�+�+��R�[�[�/�2�b�k�k�?�:�D�K��R�&�D�K���.�r$c�Z�[UR5URUR4$r;)r\rMrNrP�r_s r%r2�_EventKey._keys���4�;�;�����$�+�+�>�>r$c��XRLaU$[URURURUR44US9$�N)rW)r4rKrMrNrOrR)r_rQs  r%�with_wrapper�_EventKey.with_wrappers?���o�o�%��K������������$�$� ��
r$c��XRLaU$[URURURUUR45S9$rf)rRrKrMrNrOrQ)r_rRs  r%�with_dispatch_target�_EventKey.with_dispatch_targets?���2�2�2��K����������������
r$c��URSS5nURSS5nURSS5nURURURp�n[	UR46U5n	U	R
X�5n47URU485n[	URR49RUR5n[US5(aUR5 U(dU(a?UR[R"URUS95R"U0UD6 gURR50R"U/UQ70UD6 g)N�onceF�_once_unless_exception�named�_sa_warn)�retry_on_exception)r*rRrNr4�getattrr�_adjust_fn_specrg�_events�hasattrrpr�	only_once�listen�_listen)r_�args�kwrm�once_unless_exceptionrorMrNrO�dispatch_collection�adjusted_fn�
stub_functions            r%rw�_EventKey.listens7���v�v�f�e�$�� "���'?�� G�����w��&��
� � ��O�O��O�O���&�f�o�o�z�B��)�9�9�"�D��� � ��-���� � �)�)�1�1�4�?�?�51�
��=�*�-�-��"�"�$��(��������O�O�8M��
��f�	
��	
"�!�	
"�
� � �)�)�1�1�$�D��D��Dr$c	�~�URnU[;aA[R"SUR<SUR52<SUR<S35e[RU5nUR5H=up4U"5nU"5nUcMUcMURURU55 M? g)NzNo listeners found for event z / � )r2r'r�InvalidRequestErrorrMrNrOr*�items�removerg)r_r.r/�collection_ref�listener_ref�53collection�listener_fns       r%r��_EventKey.remove<s����i�i���(�(��)�)��;�;�������:��
�54*�-�-�c�2��,8�,>�,>�,@�(�N�'�)�J�&�.�K��%�+�*A��!�!�$�"3�"3�K�"@�A�	-Ar$c�(�UR[;$)z6Return True if this event key is registered to listen.)r2r'rcs r%�contains�_EventKey.containsMs���y�y�.�.�.r$c��URURpv[URU5nUR	UR5n	U(aU	R5 U(aU	R
X5 gU	RX5 gr;)rRrNrrr�55for_modify�_set_asyncio�insert�append)56r_�	propagater�ro�retval�asynciorMrNr|r�s57          r%�base_listen�_EventKey.base_listenQsh��"�1�1�4�?�?�58�%�f�o�o�z�B��(�3�3�F�O�O�D�59���#�#�%�����d�.����d�.r$c�@�UR=(d UR$r;)rQrOrcs r%r4�_EventKey._listen_fnfs���|�|�&�t�w�w�&r$c�\�[X5(aURUR5 gg�NTF)r9r�r4�r_r6�list_s   r%�append_to_list�_EventKey.append_to_listjs%��60!��-�-��L�L����)��r$c�P�[X5 URUR5 gr;)r<r�r4r�s   r%�remove_from_list�_EventKey.remove_from_listus��61	!��-�
���T�_�_�%r$c�\�[X5(aURUR5 ggr�)r9�62appendleftr4r�s   r%�prepend_to_list�_EventKey.prepend_to_list}s'��63!��-�-����T�_�_�-��r$)rRrOrPrQrNrMr;)64rMrrNrSrOrTrRrrWrV)�return�_EventKeyTupleType)rQrTr��_EventKey[_ET])rRrr�r�)ryrrzrr��None)r�r�)r��bool)FFFNF)r�r�r�r�ror�r�zOptional[bool]r�r�r�r�)r�rT)r6�RefCollection[_ET]r��Deque[_ListenerFnType]r�r�)r6r�r�r�r�r�)rrrrr r!r"r`�propertyr2rgrjrwr�r�r�r4r�r�r�r#rr$r%rKrK�sa��.��I�
�K��O�������'�'�/3�
/��/��/�
�	/�65�/�,�
/�$�?��?�66�67�E�@B�"/� ���!%��
/��/��/��	/�68�/��
/�69�/�*�'��'�	�!�	�&�	�70�		�&�!�&�&�&�71�	&�	�!�	�&�	�72�		r$rK)r,zweakref.ref[Any]r�r�)r5r�r6r�r�r�)r5r�r6r�r�r�)r?r�r@r�rA�Iterable[_ListenerFnType]r�r�)r6r�rAr�r�r�).r �73__future__r�collectionsrZ�typingrrrrrr	r74rrr
rr3�rr�
TYPE_CHECKING�attrr�baserrT�intrUrSr�rr�_RefCollectionToListenerType�defaultdict�dictr'r"�_ListenerToEventKeyTyper(r0r9r<rGrIrKrr$r%�<module>r�s����#���
���������������	���#� ��3��8�$���3��c�3�h��/�0���3��%7�7�8���e�=�)���� $�$� �����D�!��J��	��"��������D�!���"�	�,�"���&8��	��*.��.�&8�.�	�.�.!.� �!.� �!.�(�!.�75�	!.�H(��(�'�(�76�(�&k����kr$
codekingpro/portable-devtools · Team Ai