Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/events.cpython-39.pyc
a

��Sh�@sBdZddlmZddlmZddlmZdZGdd�dej�Z	d	S)
zYWorker Event Dispatcher Bootstep.

``Events`` -> :class:`celery.events.EventDispatcher`.
�)�
ignore_errors)�	bootsteps�)�
Connection)�EventscsHeZdZdZefZd�fdd�	Zdd�Zdd	�Zd
d�Z	dd
�Z
�ZS)rz+Service used for sending monitoring events.TFcsH|rdndg|_|p|p||_|j|_d|_t�j|fi|��dS)NZworker)�groups�send_events�enabled�event_dispatcher�super�__init__)�self�cZtask_eventsZwithout_heartbeatZwithout_gossip�kwargs��	__class__��G/usr/local/lib/python3.9/site-packages/celery/worker/consumer/events.pyrs��zEvents.__init__cCsf|�|�}|jjj|��|j|j|j|jr0dgnd|jr>|j	ndd�}|_
|rb|�|�|��dS)N�task)�hostnamer	rZbuffer_groupZon_send_buffered)
�_closeZapp�eventsZ
DispatcherZconnection_for_writerrrZhubZon_send_event_bufferedr
Z
extend_buffer�flush)r
r�prev�disrrr�start"s
�

zEvents.startcCsdS�Nr�r
rrrr�stop3szEvents.stopcCsB|jr>|j}|j|_|jr(t||jj�t||j�d|_|SdSr)r
r�
connectionr�close)r
r�
dispatcherrrrr6sz
Events._closecCs|�|�dSr)rrrrr�shutdownCszEvents.shutdown)TFF)�__name__�
__module__�__qualname__�__doc__r�requiresrrrrr"�
__classcell__rrrrrs�
rN)
r&Zkombu.commonrZceleryrrr�__all__Z
StartStopSteprrrrr�<module>s


Yohohohohohooho | Sanrei Aya