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__/heart.cpython-39.pyc
a

��Sh��@sBdZddlmZddlmZddlmZdZGdd�dej�Z	d	S)
z Worker Event Heartbeat Bootstep.�)�	bootsteps)�	heartbeat�)�Events)�Heartcs<eZdZdZefZd
�fdd�	Zdd�Zdd	�ZeZ	�Z
S)rz�Bootstep sending event heartbeats.

    This service sends a ``worker-heartbeat`` message every n seconds.

    Note:
        Not to be confused with AMQP protocol level heartbeats.
    FNcs,||_||_d|_t�j|fi|��dS�N)�enabled�heartbeat_interval�heart�super�__init__)�self�cZwithout_heartbeatr	�kwargs��	__class__��F/usr/local/lib/python3.9/site-packages/celery/worker/consumer/heart.pyrszHeart.__init__cCs$t�|j|j|j�|_|j��dSr)rr�timerZevent_dispatcherr	r
�start�r
rrrrrs�zHeart.startcCs|jo|j��|_dSr)r
�stoprrrrr"sz
Heart.stop)FN)�__name__�
__module__�__qualname__�__doc__r�requiresrrr�shutdown�
__classcell__rrrrr
s�rN)
rZceleryrZ
celery.workerr�eventsr�__all__Z
StartStopSteprrrrr�<module>s


Yohohohohohooho | Sanrei Aya