Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/events.cpython-39.pyc
Ðазад
a t�h � @ sB d Z ddlmZ ddlmZ ddlmZ dZG dd� dej�Z d S ) zYWorker Event Dispatcher Bootstep. ``Events`` -> :class:`celery.events.EventDispatcher`. � )� ignore_errors)� bootsteps� )� Connection)�Eventsc sH e Zd ZdZefZd� fdd� Zdd� Zdd � Zd d � Z d d � Z � Z S )r z+Service used for sending monitoring events.TFc sH |rd ndg| _ |p | p | | _| j| _d |_t� j|fi |�� d S )NZworker)�groups� send_events�enabled�event_dispatcher�super�__init__)�self�cZ task_eventsZwithout_heartbeatZwithout_gossip�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/worker/consumer/events.pyr s ��zEvents.__init__c C sf | � |�}|jjj|�� |j| j| j|jr0dgnd |jr>|j nd d� }|_ |rb|� |� |� � d S )N�task)�hostnamer r Z buffer_groupZon_send_buffered) �_closeZapp�eventsZ DispatcherZconnection_for_writer r r ZhubZon_send_event_bufferedr Z extend_buffer�flush)r r �prev�disr r r �start" s � z Events.startc C s d S �Nr �r r r r r �stop3 s z Events.stopc C sB |j r>|j }|j| _|jr(t||jj� t||j� d |_ |S d S r )r r � connectionr �close)r r � dispatcherr r r r 6 s z Events._closec C s | � |� d S r )r r r r r �shutdownC s zEvents.shutdown)TFF) �__name__� __module__� __qualname__�__doc__r �requiresr r r r r" � __classcell__r r r r r s � r N) r& Z kombu.commonr Zceleryr r r �__all__Z StartStopStepr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка