Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/__pycache__/heartbeat.cpython-39.pyc
Ðазад
a t�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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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 )�freqZactive� 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
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0.01 |
proxy
|
phpinfo
|
ÐаÑтройка