σ P'—^c@@s–dZddlmZddlZddlmZddlmZddlm Z m Z dgZ ej ej fZd „Zdefd „ƒYZdS( s Signal class.i(tabsolute_importNi(tsaferef(trange(t PromiseProxytProxytSignalcC@sSt|tƒr|jƒ}nt|dƒrIt|jƒt|jƒfSt|ƒS(Nt__func__(t isinstanceRt_get_current_objectthasattrtidt__self__R(ttarget((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt_make_ids cB@steZdZd d„Zd„Zd„Zd d ed d„Zd„Z d„Z d„Z d„Z d „Z e ZRS( s«Base class for all signals .. attribute:: receivers Internal attribute, holds a dictionary of `{receiverkey (id): weakref(receiver)}` mappings. cC@s1g|_|dkrg}nt|ƒ|_dS(s•Create a new signal. :param providing_args: A list of the arguments this signal can pass along in a :meth:`send` call. N(t receiverstNonetsettproviding_args(tselfR((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt__init__"s   cC@s%|j|d|jƒd|d|ƒS(Ntsendertweakt dispatch_uid(tconnectR(RtfunRRR((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt_connect_proxy.sc@sVdtd‡fd†}|rIt|dƒrI||d|Ž|dƒS|||ŽS(sχConnect receiver to sender for signal. :param receiver: A function or an instance method which is to receive signals. Receivers must be hashable objects. if weak is :const:`True`, then receiver must be weak-referencable (more precisely :func:`saferef.safe_ref()` must be able to create a reference to the receiver). Receivers must be able to accept keyword arguments. If receivers have a `dispatch_uid` attribute, the receiver will not be added if another receiver already exists with that `dispatch_uid`. :keyword sender: The sender to which the receiver should respond. Must either be of type :class:`Signal`, or :const:`None` to receive events from any sender. :keyword weak: Whether to use weak references to the receiver. By default, the module will attempt to use weak references to the receiver objects. If this parameter is false, then strong references will be used. :keyword dispatch_uid: An identifier used to uniquely identify a particular instance of a receiver. This will usually be a string, though it may be anything hashable. c@s‡‡‡‡fd†}|S(Nc@sΝ|}tˆtƒr5ˆjˆj|ˆˆˆƒ|SˆrPˆtˆƒf}nt|ƒtˆƒf}ˆr‰tj|dˆjƒ}nx=ˆjD]\}}||kr“Pq“q“Wˆjj ||fƒ|S(Nt on_delete( RRt__then__RR Rtsafe_reft_remove_receiverRtappend(Rtreceivert lookup_keytr_keyt_(RRRR(s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt_connect_signalTs  ((RRRR#(R(RRRs>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt_handle_optionsRsiiN(RtTruetcallable(RtargstkwargsR$((Rs>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyR4sc C@s„|r|t|ƒf}nt|ƒt|ƒf}xJtt|jƒƒD]3}|j|\}}||krI|j|=PqIqIWdS(sDisconnect receiver from sender for signal. If weak references are used, disconnect need not be called. The receiver will be removed from dispatch automatically. :keyword receiver: The registered receiver to disconnect. May be none if `dispatch_uid` is specified. :keyword sender: The registered sender to disconnect. :keyword weak: The weakref state to disconnect. :keyword dispatch_uid: the unique identifier of the receiver to disconnect N(R RtlenR( RRRRRR tindexR!R"((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt disconnectus  cK@sbg}|js|SxH|jt|ƒƒD]1}|d|d||}|j||fƒq)W|S(sSend signal from sender to all connected receivers. If any receiver raises an error, the error propagates back through send, terminating the dispatch loop, so it is quite possible to not have all receivers called if a raises an error. :param sender: The sender of the signal. Either a specific object or :const:`None`. :keyword \*\*named: Named arguments which will be passed to receivers. :returns: a list of tuple pairs: `[(receiver, response), … ]`. tsignalR(Rt_live_receiversR R(RRtnamedt responsesRtresponse((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pytsend’s cK@sg}|js|Sxu|jt|ƒƒD]^}y|d|d||}Wn&tk rs}|j||fƒq)X|j||fƒq)W|S(sέSend signal from sender to all connected receivers catching errors. :param sender: The sender of the signal. Can be any python object (normally one registered with a connect if you actually want something to occur). :keyword \*\*named: Named arguments which will be passed to receivers. These arguments must be a subset of the argument names defined in :attr:`providing_args`. :returns: a list of tuple pairs: `[(receiver, response), … ]`. :raises DispatcherKeyError: if any receiver raises an error (specifically any subclass of :exc:`Exception`), the error instance is returned as the result for that receiver. R,R(RR-R t ExceptionR(RRR.R/RR0terr((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt send_robustͺs cC@s•tdƒ}g}x||jD]q\\}}}||ksF||krt|tƒr}|ƒ}|dk rŠ|j|ƒqŠq|j|ƒqqW|S(s―Filter sequence of receivers to get resolved, live receivers. This checks for weak references and resolves them, then returning only live receivers. N(R RRRt WEAKREF_TYPESR(Rt senderkeytnone_senderkeyRt receiverkeyt r_senderkeyR((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyR-Νs   cC@sg}x3|jD](\}}||kr|j|ƒqqWxM|D]E}x<t|jƒD]+\}\}}||krY|j|=qYqYWqCWdS(s'Remove dead receivers from connections.N(RRt enumerate(RRt to_removetkeytconnected_receivertidxR!R"((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyRβs  " cC@sdjt|ƒjƒS(Ns (tformatttypet__name__(R((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyt__repr__ξsN(RAt __module__t__doc__RRRRR%R+R1R4R-RRBt__str__(((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyRs  A    #  (RDt __future__RtweakreftRt celery.fiveRt celery.localRRt__all__t ReferenceTypetBoundMethodWeakrefR5R tobjectR(((s>/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/dispatch/signal.pyts