File: //usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/heart.cpython-39.pyc
a
X>h� � @ sB d Z ddlmZ ddlmZ ddlmZ dZG dd� dej�Z d S )
z Worker Event Heartbeat Bootstep.� )� bootsteps)� heartbeat� )�Events)�Heartc s< e Zd ZdZefZd
� fdd� Zdd� Zdd � ZeZ � Z
S ) r z�Bootstep sending event heartbeats.
This service sends a ``worker-heartbeat`` message every n seconds.
Note:
Not to be confused with AMQP protocol level heartbeats.
FNc s, | | _ || _d |_t� j|fi |�� d S �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 s zHeart.__init__c C s$ t �|j|j| j�|_|j�� d S r )r r �timerZevent_dispatcherr r
�start�r
r r r r r s �z Heart.startc C s |j o|j �� |_ d S r )r
�stopr r r r r " s z
Heart.stop)FN) �__name__�
__module__� __qualname__�__doc__r �requiresr r r �shutdown�
__classcell__r r r r r
s �r N)
r Zceleryr Z
celery.workerr �eventsr �__all__Z
StartStopStepr r r r r �<module> s