/opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/event/__pycache__
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/event/__pycache__/attr.cpython-311.pyc (23793B)
(uSm UM d d Z ddlmZ ddlmZ ddlZddlmZ ddlZddlm Z ddlm
Z
d d
lm Z d d lm Z d d l m
Z
G d
de j Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e ZdS ) a Attribute implementation for _Dispatch classes.
The various listener targets for a particular event class are represented
as attributes, which refer to collections of listeners to be fired off.
These collections can exist at the class level as well as at the instance
level. An event is fired off using code like this::
some_object.dispatch.first_connect(arg1, arg2)
Above, ``some_object.dispatch`` would be an instance of ``_Dispatch`` and
``first_connect`` is typically an instance of ``_ListenerCollection``
if event listeners are present, or ``_EmptyListener`` if none are present.
The attribute mechanics here spend effort trying to ensure listener functions
are available with a minimum of function call overhead, that unnecessary
objects aren't created (i.e. many empty per-instance listener collections),
as well as that everything is garbage collectable when owning references are
lost. Other features such as "propagation" of listener functions across
many ``_Dispatch`` instances, "joining" of multiple ``_Dispatch`` instances,
as well as support for subclass propagation (e.g. events assigned to
``Pool`` vs. ``QueuePool``) are all implemented here.
)absolute_import)with_statementN)chain )legacy)registry )exc)util) threadingc e Zd ZdZd ZdS )
RefCollection)refc @ t j | t j S N)weakrefr r _collection_gcedselfs i/builddir/build/BUILD/cloudlinux-venv-1.0.12/venv/lib64/python3.11/site-packages/sqlalchemy/event/attr.py_memoized_attr_refz RefCollection._memoized_attr_ref1 s {4!:;;; N)__name__
__module__ __qualname__ __slots__r r r r r . s( I< < < <
z,_ClsLevelDispatch.__init__..Z s
1 r )key)r r1 r inspect_getfullargspecargsr2 boolvarkwr3 listreversedsortedgetattrr4 r _augment_fn_docs__doc__r WeakKeyDictionaryr5 )r parent_dispatch_clsfnargspecs r __init__z_ClsLevelDispatch.__init__R s K -b11 abb)7=)) !% B 4b99~~
"
"
,T3FKK
244r c |r| | }| j r> t j |d }t j | || }n# t $ r Y nw xY w|S )NT)no_self)_wrap_fn_for_kwr4 r get_callable_argspecr _wrap_fn_for_legacy TypeError)r rJ namedrK s r _adjust_fn_specz!_ClsLevelDispatch._adjust_fn_specb s *%%b))B ! C
C 3BEEE /b'BB
s A
AAc fd}|S )Nc t t j | }| | di |S )Nr )dictzipr2 update)r? kwargdictrJ r s r wrap_kwz2_ClsLevelDispatch._wrap_fn_for_kw..wrap_kwo s@ 3t~t4455G NN2 2==== r r )r rJ r\ s `` r rO z!_ClsLevelDispatch._wrap_fn_for_kwn s) ! ! ! ! ! !
r c |j }t |t s
J d t |dd st j d|z |g}|r| d }| | ||ur || j vr|
| nC|| j vr| | | j | |j
|t j || d S Nz*Class-level Event targets must be classes._sa_propagate_class_eventsTz.Can't assign an event directly to the %s classr )dispatch_target
isinstancetyperE r
InvalidRequestErrorpopr' __subclasses__r5 update_subclass_assign_cls_collection
appendleft
_listen_fnr _stored_in_collectionr event_key propagatetargetstackclss r insertz_ClsLevelDispatch.insertv s> * D
8 8 7 8 8
v ;TBB )@6I
E))A,,C LL++-- . . .& S%>%>$$S))))dn,,//444s#..y/CDDD E &y$77777r c |j }t |t s
J d t |dd st j d|z |g}|r| d }| | ||ur || j vr|
| nC|| j vr| | | j | |j
|t j || d S r^ )r` ra rb rE r
rc rd r' re r5 rf rg r# ri r rj rk s r r# z_ClsLevelDispatch.append s> * D
8 8 7 8 8
v ;TBB )@6I
A))A,,C LL++-- . . .& S%>%>$$S))))dn,,//444s#**9+?@@@ A &y$77777r c t |dd r t j | j |< d S t | j |< d S )Nr_ T)rE collectionsdequer5 r )r rn s r rg z(_ClsLevelDispatch._assign_cls_collection sJ 67 > > 9%0%6%8%8DN6 " " "%6%8%8DN6 " " "r c || j vr| | | j | |j dd D ]7}|| j v r, fd| j | D 8d S )Nr c g | ]}|v| S r r ).0rJ clslevels r
z5_ClsLevelDispatch.update_subclass.. s# LLLB89K9KR9K9K9Kr )r5 rg __mro__r' )r rn rp ry s @r rf z!_ClsLevelDispatch.update_subclass s ' ' ' ' / / />&)>!""% Cdn$$LLLL$."5LLL r c |j }|g}|rl| d }| | || j v r%| j | |j |lt j || d S r: ) r` rd r' re r5 r) ri r _removed_from_collection)r rl rn ro rp s r r) z_ClsLevelDispatch.remove s * A))A,,C LL++-- . . .dn$$s#**9+?@@@ A
))T:::::r c t }| j D ]+}| | | ,t j | | dS )z Clear all class level listenersN)setr5 valuesrY r. r _clear)r to_clear
dispatchers r r. z_ClsLevelDispatch.clear si 55 .//11 J OOJ ' ' ' h'''''r c | S )zReturn an event collection which can be modified.
For _ClsLevelDispatch at the class level of
a dispatcher, this returns self.
r r objs r
for_modifyz _ClsLevelDispatch.for_modify r N)r r r rG r rL rT rO rq r# rg rf r) r. r r r r r0 r0 F s <<I5 5 5
8 8 8*8 8 8*9 9 9 ; ; ;( ( ( r r0 c e Zd ZdZd ZdS )_InstanceLevelDispatchr c 8 | j || S r )parentrT r rJ rS s r rT z&_InstanceLevelDispatch._adjust_fn_spec s {**2u555r N)r r r r rT r r r r r s( I6 6 6 6 6r r c t e Zd ZdZ e ZdZdZd Zd Z d Z
e
xZ xZ xZ
xZxZZd Zd Zd Zd
ZeZd S ) _EmptyListenerzServes as a proxy interface to the events
served by a _ClsLevelDispatch, when there are no
instance-level events present.
Is replaced by _ListenerCollection when instance-level
events are added.
r )r parent_listenersr1 c ||j vr| | || _ |j | | _ |j | _ d S r )r5 rf r r r1 r r
target_clss r rL z_EmptyListener.__init__ sH V - - - " ": . . . & 0 < K r c t | j |j }t || j | u rt || j | n*t
t || j t sJ |S )zReturn an event collection which can be modified.
For _EmptyListener at the instance level of
a dispatcher, this generates a new
_ListenerCollection, applies it to the instance,
and returns it.
)_ListenerCollectionr
_instance_clsrE r1 setattrra _JoinedListener)r r results r r z_EmptyListener.for_modify sm %T[#2CDD 3 " "d * * CF + + + + gc49 5 5GG G GG
r c t d )Nzneed to call for_modify()NotImplementedErrorr r? rZ s r
_needs_modifyz _EmptyListener._needs_modify s !"=>>>r c * | j D ]
} ||i | dS zExecute this event.N)r r r? rZ rJ s r __call__z_EmptyListener.__call__ s3 ' B BOOOOO r c * t | j S r )lenr r s r __len__z_EmptyListener.__len__ s 4()))r c * t | j S r )r+ r r s r r, z_EmptyListener.__iter__
D)***r c * t | j S r )r@ r r s r __bool__z_EmptyListener.__bool__
r r N)r r r rG frozensetrm listenersr rL r r exec_onceexec_once_unless_exceptionrq r# r) r. r r r, r __nonzero__r r r r r s II4I ? ? ?
,99I 9"999 5 * * *+ + ++ + + KKKr r c F e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z e Z d
S ) _CompoundListener_exec_once_mutex
_exec_oncec ( t j S r )r Lockr s r _memoized_attr__exec_once_mutexz1_CompoundListener._memoized_attr__exec_once_mutex s ~ r c | j 5 | j s1 | |i | d}n# d} xY w |r|sd| _ n# |r|sd| _ w xY wd d d d S # 1 swxY w Y d S )NFTr )r retry_on_exceptionr? rZ exceptions r _exec_once_implz!_CompoundListener._exec_once_impl s
"
/
/?
//D$%"%%% %II $I
% /,> /*. % /,> /*.....
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/s/ A
1!1 A
>AAAc : | j s | j dg|R i | dS dS )z]Execute this event, but only if it has not been
executed already for this collection.FNr r r s r r z_CompoundListener.exec_once& sA 5 D 4 4 4 4 4 4 4 4 4 5 5r c : | j s | j dg|R i | dS dS )at Execute this event, but only if it has not been
executed already for this collection, or was called
by a previous exec_once_unless_exception call and
raised an exception.
If exec_once was already called, then this method will never run
the callable regardless of whether it raised or not.
.. versionadded:: 1.3.8
TNr r s r r z,_CompoundListener.exec_once_unless_exception- sA 4 D 3 3 3 3 3 3 3 3 3 4 4r c N | j D ]
} ||i | | j D ]
} ||i | dS r )r r r s r r z_CompoundListener.__call__< sW ' B BOOOOO. B BOOOOO r c T t | j t | j z S r )r r r r s r r z_CompoundListener.__len__D s" 4())C,?,???r c 6 t | j | j S r )r r r r s r r, z_CompoundListener.__iter__G s T*DN;;;r c 8 t | j p| j S r )r@ r r r s r r z_CompoundListener.__bool__J s DN;d&;<<.} sF
---" .DN""
#""r N)r r rm rY r' unionr _stored_in_collection_multi)r r& r existing_listenersother_listeners to_associater s ` ` @r _updatez_ListenerCollection._updatev s "^ #$6 7 7 eo...
_
!!/222 ,,_== ,T5,GGGGGr c | | | j r#|r#| j |j d S d S d S r )prepend_to_listr rm addri r rl rm s r rq z_ListenerCollection.insert sW $ $T4> : : 9
9""9#788888 9 9
9
9r c | | | j r#|r#| j |j d S d S d S r )append_to_listr rm r ri r s r r# z_ListenerCollection.append sW # #D$. 9 9 9
9""9#788888 9 9
9
9r c | j |j | j |j t j || d S r )r r) ri rm discardr r} r rl s r r) z_ListenerCollection.remove sM i 2333 y 3444))T:::::r c t j | | j | j | j d S r )r r r rm r. r s r r. z_ListenerCollection.clear sD dn--- r N)T) r r r rG r rL r r rq r# r) r. r r r r r P s I H H H H(9 9 9
9 9 9
; ; ;
r r c R e Zd ZdZd Zed Zd Zd Zd Z d Z
d Z d Z d
S ) r )r r1 localr c V d| _ || _ || _ || _ | j | _ d S r )r r r1 r r )r r r1 r s r rL z_JoinedListener.__init__ s.
$
r c 6 t | j | j S r )rE r r1 r s r r z_JoinedListener.listeners s t{DI...r c 8 | j || S r )r rT r s r rT z _JoinedListener._adjust_fn_spec s z))"e444r c R | j | x| _ | _ | S r )r r r r s r r z_JoinedListener.for_modify s& -1Z-B-B3-G-GG
T* r c < | j || d S r )r rq r s r rq z_JoinedListener.insert
)Y/////r c < | j || d S r )r r# r s r r# z_JoinedListener.append r r c : | j | d S r )r r) r s r r) z_JoinedListener.remove s
)$$$$$r c t r r r s r r. z_JoinedListener.clear s !###r N)
r r r r rL propertyr rT r rq r# r) r. r r r r r s =I+ + + / / X/5 5 5 0 0 00 0 0% % %$ $ $ $ $r r )rG
__future__r r rt itertoolsr r r r r
r r
MemoizedSlotsr objectr r0 r r r r r r r r r s+ 0 ' & & & & & % % % % % % < < < <