File: //usr/local/lib/python3.9/site-packages/celery/worker/__pycache__/heartbeat.cpython-39.pyc
a
X>h; � @ sF d Z ddlmZ ddlmZ ddlmZmZmZ dZ G dd� 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 @ s4 e Zd ZdZd dd�Zd
dd�Zdd � Zd
d � ZdS )r a@ 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.
Nc C sV || _ || _t|pd�| _d | _| jj�| j� | jj�| j � t
j rLt
j nd | _
d S )Ng @)�timer�eventer�float�interval�trefZ
on_enabled�add�startZ on_disabled�stopr Z 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__Tc C sB | j d ur| j | d� | jj|f| jtt�td t� |d�t��S )N)Zsenderr )�freq�active� processedZloadavg�retry) r r
r r �lenr r r r )r �eventr r r r �_send' s
��z Heart._sendc C s, | j jr(| �d� | j�| j| jd�| _d S )Nz
worker-online)zworker-heartbeat)r
�enabledr r Zcall_repeatedlyr r
�r r r r r 1 s
�z Heart.startc C s8 | j d ur | j�| j � d | _ | jjr4| jddd� d S )Nzworker-offlineF)r )r
r �cancelr
r r r r r r r 8 s
z
Heart.stop)N)T)�__name__�
__module__� __qualname__�__doc__r r r r r r r r r s
r N) r$ Zcelery.signalsr Zcelery.utils.sysinfor �stater r r �__all__r r r r r �<module> s