§ `¦·f#ãó”—dZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z ddl mZdd lmZmZmZd ZGd „d ¦«ZdS) zEvent dispatcher sends events.éN)Ú defaultdictÚdeque)ÚProducer)Úapp_or_default)Ú anon_nodename)Ú utcoffseté)ÚEventÚ get_exchangeÚ group_from)ÚEventDispatchercó°—eZdZdZdhZdZdZdZ dd„Zd„Z d „Z d „Z d „Z d e fd „Zd defd„Zd ed de fd„Zdd„Zd„Zd„Zd„Zd„Zeee¦«ZdS)r a0Dispatches event messages. Arguments: connection (kombu.Connection): Connection to the broker. hostname (str): Hostname to identify ourselves as, by default uses the hostname returned by :func:`~celery.utils.anon_nodename`. groups (Sequence[str]): List of groups to send events for. :meth:`send` will ignore send requests to groups not in this list. If this is :const:`None`, all events will be sent. Example groups include ``"task"`` and ``"worker"``. enabled (bool): Set to :const:`False` to not actually publish any events, making :meth:`send` a no-op. channel (kombu.Channel): Can be used instead of `connection` to specify an exact channel to use when sending events. buffer_while_offline (bool): If enabled events will be buffered while the connection is down. :meth:`flush` must be called as soon as the connection is re-established. Note: You need to :meth:`close` this after use. ÚsqlNTr éc óú—t|p|j¦«|_||_||_|p t ¦«|_||_| p t¦«|_| |_ | |_ tt¦«|_ tj¦«|_d|_t%¦«|_|p|jjj|_t/¦«|_t/¦«|_t/|pg¦«|_t6j t6j g|_|jj|_| |_ |s|r|jj!|_||_"|jp|j #¦«} tI| |jjj%¬¦«|_&| j'j(|j)vrd|_"|j"r| *¦«d|ji|_+tYj-¦«|_.dS)N)ÚnameFÚhostname)/rÚappÚ connectionÚchannelrrÚbuffer_while_offlineÚ frozensetÚ buffer_groupÚ buffer_limitÚon_send_bufferedrÚlistÚ _group_bufferÚ threadingÚLockÚmutexÚproducerrÚ_outbound_bufferÚconfÚevent_serializerÚ serializerÚsetÚ on_enabledÚ on_disabledÚgroupsÚtimeÚtimezoneÚaltzoneÚtzoffsetÚclockÚ delivery_modeÚclientÚenabledÚconnection_for_writer Úevent_exchangeÚexchangeÚ transportÚ driver_typeÚDISABLED_TRANSPORTSÚenableÚheadersÚosÚgetpidÚpid)Úselfrrr1rrrr%r)r/rrrÚconninfos úJ/var/www/html/env/lib/python3.11/site-packages/celery/events/dispatcher.pyÚ__init__zEventDispatcher.__init__:s©€õ" # /¨¬Ñ2Ô2ˆŒØ$ˆŒØˆŒ Ø Ð3¥M¡O¤OˆŒ Ø$8ˆÔ!Ø(Ð7­I©K¬KˆÔØ(ˆÔØ 0ˆÔÝ(­Ñ.Ô.ˆÔÝ”^Ñ%Ô%ˆŒ ؈Œ Ý %¡¤ˆÔØ$ÐF¨¬¬ Ô(FˆŒÝ™%œ%ˆŒÝ™5œ5ˆÔݘ&˜, BÑ'Ô'ˆŒ Ýœ-˜­$¬,¨Ð7ˆŒ Ø”X”^ˆŒ Ø*ˆÔØð 8˜gð 8Ø%Ô0Ô7ˆDŒO؈Œ Ø”?ÐE d¤h×&CÒ&CÑ&EÔ&EˆÝ$ XØ*.¬(¬-Ô*FðHñHôHˆŒ à Ô Ô )¨TÔ-EÐ EÐ EØ ˆDŒLØ Œ<ð Ø KŠK‰MŒMˆMØ" D¤MÐ2ˆŒ Ý”9‘;”;ˆŒˆˆócó—|S©N©©r=s r?Ú __enter__zEventDispatcher.__enter__^s€Øˆ rAcó.—| ¦«dSrC)Úclose)r=Úexc_infos r?Ú__exit__zEventDispatcher.__exit__as€Ø Š ‰ Œ ˆ ˆ ˆ rAcó˜—t|jp|j|j|jd¬¦«|_d|_|jD] }|¦«Œ dS)NF)r4r%Ú auto_declareT)rrrr4r%r!r1r'©r=Úcallbacks r?r8zEventDispatcher.enabledsa€Ý  ¤Ð!@°´Ø*.¬-Ø,0¬OØ.3ð5ñ5ô5ˆŒ ðˆŒ Øœð ð ˆHØ ˆH‰JŒJˆJˆJð ð rAcóv—|jr/d|_| ¦«|jD]}|¦«Œ dSdS)NF)r1rHr(rMs r?ÚdisablezEventDispatcher.disablemsS€Ø Œ<ð Ø ˆDŒLØ JŠJ‰LŒLˆLØ Ô,ð ð Ø‘ ” ð  ð ð ð rAFc ó—|rdn|j ¦«}||f|jt¦«|j|dœ|¤Ž}|j5|j||fd| dd¦«i|¤Žcddd¦«S#1swxYwYdS)auPublish event using custom :class:`~kombu.Producer`. Arguments: type (str): Event type name, with group separated by dash (`-`). fields: Dictionary of event fields, must be json serializable. producer (kombu.Producer): Producer instance to use: only the ``publish`` method will be called. retry (bool): Retry in the event of connection failure. retry_policy (Mapping): Map of custom retry policy options. See :meth:`~kombu.Connection.ensure`. blind (bool): Don't set logical clock value (also don't forward the internal logical clock). Event (Callable): Event type used to create event. Defaults to :func:`Event`. utcoffset (Callable): Function returning the current utc offset in hours. N©rrr<r.Ú routing_keyú-ú.)r.Úforwardrrr<r Ú_publishÚreplace) r=ÚtypeÚfieldsr!Úblindr Úkwargsr.Úevents r?ÚpublishzEventDispatcher.publishts€ð&Ð7 4¤:×#5Ò#5Ñ#7Ô#7ˆØdð; T¤]½i¹k¼kØœ(¨%ð;ð;Ø39ð;ð;ˆà ŒZð Oð OØ 4”= ¨ðOðOØ-1¯\ª\¸#¸sÑ-CÔ-CðOØGMðOðOð Oð Oð Oð Oñ Oô Oð Oð Oð Oð Oð Oð Oøøøð Oð Oð Oð Oð Oð OsÁ %A;Á;A?ÂA?c óö—|j} | |||j|||g|j|j|j¬¦ « dS#t $r0}|js‚|j  |||f¦«Yd}~dSd}~wwxYw)N)rSr4ÚretryÚ retry_policyÚdeclarer%r9r/) r4r^rr%r9r/Ú Exceptionrr"Úappend) r=r]r!rSr`rarr4Úexcs r?rWzEventDispatcher._publishŽs¿€à”=ˆð DØ × Ò ØØ'Ø!œØØ)Ø!˜ Øœ?Øœ Ø"Ô0ð ñ ô ð ð ð øõð Dð Dð DØÔ,ð ØØ Ô !× (Ò (¨%°¸cÐ)BÑ CÔ CÐ CÐ CÐ CÐ CÐ CÐ CÐ Cøøøøð Døøøs‰3>¾ A8Á%A3Á3A8c óô—|jrð|jt|¦«} }|r| |vrdS| |jvr¨|j ¦«} ||f|j|¦«|j| dœ|¤Ž} |j| } |   | ¦«t| ¦«|j kr|  ¦«dS|j r|  ¦«dSdS| |||j||||¬¦«SdS)aÆSend event. Arguments: type (str): Event type name, with group separated by dash (`-`). retry (bool): Retry in the event of connection failure. retry_policy (Mapping): Map of custom retry policy options. See :meth:`~kombu.Connection.ensure`. blind (bool): Don't set logical clock value (also don't forward the internal logical clock). Event (Callable): Event type used to create event, defaults to :func:`Event`. utcoffset (Callable): unction returning the current utc offset in hours. **fields (Any): Event fields -- must be json serializable. NrR)r[r r`ra)r1r)r rr.rVrr<rrdÚlenrÚflushrr^r!) r=rYr[rr`rar rZr)Úgroupr.r]Úbufs r?ÚsendzEventDispatcher.send¢sC€ð" Œ<ð ?Ø œK­°DÑ)9Ô)9EˆFØð ˜% vÐ-Ð-ØؘÔ)Ð)Ð)Øœ ×*Ò*Ñ,Ô,ؘ˜dðC¨T¬]Ø(1¨ © ¬ Ø"&¤(°%ðCðCà;AðCðCðÔ(¨Ô/Ø— ’ ˜5Ñ!Ô!Ð!Ýs‘8”8˜tÔ0Ò0Ð0Ø—J’J‘L”LLLLØÔ*ð,Ø×)Ò)Ñ+Ô+Ð+Ð+Ð+ð,ð,ð—|’| D¨&°$´-ÀuØ*/°uØ1=ð$ñ?ô?ð?ð! ?ð ?rAcó—|r’t|j¦«} |j5|D]"\}}}| ||j|¦«Œ# ddd¦«n #1swxYwY|j ¦«n#|j ¦«wxYw|rh|j5|j ¦«D]+\}}| ||jd|z¦«g|dd…<Œ, ddd¦«dS#1swxYwYdSdS)zFlush the outbound buffer.Nz%s.multi)rr"r rWr!ÚclearrÚitems) r=Úerrorsr)rjr]rSÚ_riÚeventss r?rhzEventDispatcher.flushÇsÌ€à ð .ÝtÔ,Ñ-Ô-ˆCð .Ø”ZðIðIØ14ðIðIÑ-˜˜{¨AØŸ š  e¨T¬]¸KÑHÔHÐHÐHðIðIðIðIñIôIðIðIðIðIðIðIøøøðIðIðIðIðÔ%×+Ò+Ñ-Ô-Ð-Ð-øÔ%×+Ò+Ñ-Ô-Ð-Ð-øøøØ ð #Ø”ð #ð #Ø%)Ô%7×%=Ò%=Ñ%?Ô%?ð#ð#‘ME˜6Ø—M’M &¨$¬-¸ÀeÑ9KÑLÔLÐLØ "F˜1˜1˜1‘IIð#ð #ð #ð #ñ #ô #ð #ð #ð #ð #ð #ð #ð #øøøð #ð #ð #ð #ð #ð #ð #ð #sA˜A7Ÿ&AÁ A7ÁAÁA7ÁAÁA7Á7BÂAC2Ã2C6Ã9C6cóD—|j |j¦«dS)z-Copy the outbound buffer of another instance.N)r"Úextend)r=Úothers r?Ú extend_bufferzEventDispatcher.extend_buffer×s"€à Ô×$Ò$ UÔ%;Ñ<Ô<Ð<Ð<ÐBØ=>ØFJð"ð"ð"ð"ðHðððððððððððð 5ðOðOðOðOð4rŠsèðØ$Ð$à € € € ØÐÐÐØ € € € Ø*Ð*Ð*Ð*Ð*Ð*Ð*Ð*àÐÐÐÐÐà%Ð%Ð%Ð%Ð%Ð%Ø0Ð0Ð0Ð0Ð0Ð0Ø'Ð'Ð'Ð'Ð'Ð'à2Ð2Ð2Ð2Ð2Ð2Ð2Ð2Ð2Ð2à €ðR9ðR9ðR9ðR9ðR9ñR9ôR9ðR9ðR9ðR9rA