?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/event/__pycache__/registry.cpython-39.pyc
???????
a ��Jh�+ � @ s� U d Z ddlmZ ddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZ dd lmZ ddlmZ ddlZddlmZ ddlmZ ejr�ddlmZ ddlmZ edef Zeeeeef f Z eee e f Z eddd�Z G dd� d�Z e d Z!e�"e#�Z$de%d < e d e f Z&e�"e#�Z'd e%d < d d!d"�d#d$�Z(d%d&d'd(�d)d*�Z)d%d&d!d(�d+d,�Z*d&d&d-d!d.�d/d0�Z+d&d-d!d1�d2d3�Z,G d4d5� d5e e �Z-dS )6aJ 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 @ s e Zd ZU dZdZded< dS )r z�represents 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. � zdispatcher[Any]�dispatchN)�__name__� __module__� __qualname__�__doc__� __slots__�__annotations__r r r �N/home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/event/registry.pyr 2 s )z weakref.ref[RefCollection[Any]]� weakref.ref[_ListenerFnType]z6Dict[_EventKeyTupleType, _RefCollectionToListenerType]�_key_to_collectionr z>Dict[weakref.ref[RefCollection[Any]], _ListenerToEventKeyType]�_collection_to_keyzweakref.ref[Any]�None)�ref�returnc C s^ t r | t vrd S td| �} t �| �}|�� D ],}|tv r,t| }|�| � |s,t�|� q,d S )Nz'weakref.ref[RefCollection[EventTarget]])r" r �pop�valuesr! )r$ �listener_to_key�key� dispatch_regr r r �_collection_gcedg s r+ �_EventKey[_ET]�RefCollection[_ET]�bool)� event_key�ownerr% c C sH | j }t| }|j}t�| j�}||v r,dS |||< t| }|||< dS )NFT)�_keyr! r$ �weakref� _listen_fnr" )r/ r0 r) r* � owner_ref� listen_refr( r r r �_stored_in_collectionx s r6 c C sV | j }t| }t�| j�}|j}|�|d � |s6t|= |tv rRt| }|�|d � d S �N)r1 r! r2 r$ r3 r& r" )r/ r0 r) r* r5 r4 r( r r r �_removed_from_collection� s r8 zIterable[_ListenerFnType])�newowner�oldowner�elementsr% c C s� |sd S |j }| j }t| }t| }|D ]�}t� |�}z || } W n tyX Y q(Y n0 z t| } W n ty| Y q(Y n0 || v r�| | |ks�J �n|| |< | ||< q(d S r7 )r$ r" r2 �KeyErrorr! ) r9 r: r; Z oldowner_refZ newowner_refZold_listener_to_keyZnew_listener_to_key� listen_fnr5 r) r* r r r �_stored_in_collection_multi� s( r> )r0 r; r% c C sT |sd S | j }t| }|D ]4}t� |�}|| }t| }|�|d � |st|= qd S r7 )r$ r" r2 r! r& )r0 r; r4 r( r= r5 r) r* r r r �_clear� s r? c @ s e Zd ZU dZdZded< ded< ded< d ed < d ed < d ed< d7dddd d d�dd�Zedd�dd��Zddd�dd�Z d dd�d d �Z d d d d �d d!�Z d d�d"d#�Z d$d�d%d&�Z d8d$d$d$d(d$d d)�d*d+�Zedd�d,d-��Zd.d/d$d0�d1d2�Zd.d/d d0�d3d4�Zd.d/d$d0�d5d6�ZdS )9� _EventKeyz$Represent :func:`.listen` arguments.)�target� identifier�fn�fn_key�fn_wrap�dispatch_targetr rA �strrB �_ListenerFnTyperC �_ListenerFnKeyTyperD r rF zOptional[_ListenerFnType]�_fn_wrapN)rA rB rC rF rJ c C sP || _ || _|| _t|tj�r6t|j�t|j�f| _ n t|�| _ || _ || _ d S r7 ) rA rB rC � isinstance�types� MethodType�id�__func__�__self__rD rE rF )�selfrA rB rC rF rJ r r r �__init__� s z_EventKey.__init__�_EventKeyTupleType)r% c C s t | j�| j| jfS r7 )rN rA rB rD �rQ r r r r1 s z_EventKey._keyr, )rE r% c C s, || j u r| S t| j| j| j| j|d�S d S �N)rJ )r3 r@ rA rB rC rF )rQ rE r r r � with_wrapper s �z_EventKey.with_wrapper)rF r% c C s, || j u r| S t| j| j| j|| jd�S d S rU )rF r@ rA rB rC rE )rQ rF r r r �with_dispatch_target s �z _EventKey.with_dispatch_targetr# )�args�kwr% c O s� |� dd�}|� dd�}|� dd�}| j| j| j }}}t|j|�} | �||�} | �| �} t| jjj| j�} t | d�r�| � � |s�|r�| �t j | j|d��j |i |�� n | jjj| g|�R i |�� d S )N�onceFZ_once_unless_exception�named�_sa_warn)Zretry_on_exception)r& rF rB r3 �getattrr Z_adjust_fn_specrV Z_events�hasattrr\ r Z only_once�listenZ_listen) rQ rX rY rZ Zonce_unless_exceptionr[ rA rB rC �dispatch_collectionZ adjusted_fnZ stub_functionr r r r_ s4 � � ����z_EventKey.listenc C st | j }|tvr(t�d| j| j| jf ��t�|�}|�� D ]4\}}|� }|� }|d ur:|d ur:|� | � |�� q:d S )Nz*No listeners found for event %s / %r / %s ) r1 r! r ZInvalidRequestErrorrA rB rC r& �items�removerV )rQ r) r* Zcollection_refZ listener_refZ collectionZ listener_fnr r r rb < s �� z_EventKey.remover. c C s | j tv S )z6Return True if this event key is registered to listen.)r1 r! rT r r r �containsM s z_EventKey.containsFzOptional[bool])� propagate�insertr[ �retval�asyncior% c C sT | j | j }}t|j|�}|�|j�} |r2| �� |rD| �| |� n | �| |� d S r7 )rF rB r] r � for_modifyZ _set_asynciore �append) rQ rd re r[ rf rg rA rB r` rh r r r � base_listenQ s z_EventKey.base_listenc C s | j p | jS r7 )rE rC rT r r r r3 f s z_EventKey._listen_fnr- zDeque[_ListenerFnType])r0 �list_r% c C s" t | |�r|�| j� dS dS d S �NTF)r6 ri r3 �rQ r0 rk r r r �append_to_listj s z_EventKey.append_to_listc C s t | |� |�| j� d S r7 )r8 rb r3 rm r r r �remove_from_listu s z_EventKey.remove_from_listc C s" t | |�r|�| j� dS dS d S rl )r6 � appendleftr3 rm r r r �prepend_to_list} s z_EventKey.prepend_to_list)N)FFFNF)r r r r r r rR �propertyr1 rV rW r_ rb rc rj r3 rn ro rq r r r r r@ � s8 � � r@ ).r � __future__r � collectionsrL �typingr r r r r r r r r r r r2 � r r � TYPE_CHECKING�attrr �baser rH �intrI rG rS r r Z _RefCollectionToListenerType� defaultdict�dictr! r Z_ListenerToEventKeyTyper" r+ r6 r8 r> r? r@ r r r r �<module> sX �� ��� $
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????