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/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

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

��Sh;�@sFdZddlmZddlmZddlmZmZmZdZ	Gdd�d�Z
d	S)
z�Heartbeat service.

This is the internal thread responsible for sending heartbeat events
at regular intervals (may not be an actual thread).
�)�heartbeat_sent)�load_average�)�
SOFTWARE_INFO�active_requests�all_total_count)�Heartc@s4eZdZdZddd�Zd
dd�Zdd	�Zd
d�ZdS)ra@Timer sending heartbeats at regular intervals.

    Arguments:
        timer (kombu.asynchronous.timer.Timer): Timer to use.
        eventer (celery.events.EventDispatcher): Event dispatcher
            to use.
        interval (float): Time in seconds between sending
            heartbeats.  Default is 2 seconds.
    NcCsV||_||_t|pd�|_d|_|jj�|j�|jj�|j	�t
jrLt
jnd|_
dS)Ng@)�timer�eventer�float�interval�trefZ
on_enabled�add�startZon_disabled�stoprZ	receivers�send�_send_sent_signal)�selfr	r
r�r�A/usr/local/lib/python3.9/site-packages/celery/worker/heartbeat.py�__init__s�zHeart.__init__TcCsB|jdur|j|d�|jj|f|jtt�tdt�|d�t��S)N)Zsenderr)�freq�active�	processedZloadavg�retry)	rr
rr�lenrrrr)r�eventrrrr�_send's
��zHeart._sendcCs,|jjr(|�d�|j�|j|jd�|_dS)Nz
worker-online)zworker-heartbeat)r
�enabledrr	Zcall_repeatedlyrr
�rrrrr1s


�zHeart.startcCs8|jdur|j�|j�d|_|jjr4|jddd�dS)Nzworker-offlineF)r)r
r	�cancelr
rrrrrrr8s

z
Heart.stop)N)T)�__name__�
__module__�__qualname__�__doc__rrrrrrrrrs




rN)r$Zcelery.signalsrZcelery.utils.sysinfor�staterrr�__all__rrrrr�<module>s


Yohohohohohooho | Sanrei Aya