Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/tasks.cpython-39.pyc
Ðазад
a t�h� � @ s` d Z ddlmZmZ ddlmZ ddlmZ ddlm Z dZ ee �Z e j Z G dd � d ej�Zd S ) z Worker Task Consumer Bootstep.� )�QoS� ignore_errors)� bootsteps)� get_logger� )�Mingle)�Tasksc sF e Zd ZdZefZ� fdd�Zdd� Zdd� Zdd � Z d d � Z � Z S ) r z,Bootstep starting the task message consumer.c s$ d |_ |_t� j|fi |�� d S )N)� task_consumer�qos�super�__init__)�self�c�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/tasks.pyr s zTasks.__init__c s^ � � � � jj �� jj�d� j�� � jjj� j� j d�� _ � �fdd�}t |� j�� _ dS )zStart task consumer.r )�on_decode_errorc s � j j| �d�S )N)�prefetch_countZ apply_global)r r )r �r Z qos_globalr r �set_prefetch_count* s �z'Tasks.start.<locals>.set_prefetch_countN) Zupdate_strategies� connectionZqos_semantics_matches_specZdefault_channelZ basic_qosZinitial_prefetch_countZappZamqpZ TaskConsumerr r r r )r r r r r r �start s ��z Tasks.startc C s |j r td� t||j j� dS )zStop task consumer.zCanceling task consumer...N)r �debugr �cancel�r r r r r �stop1 s z Tasks.stopc C s0 |j r,| �|� td� t||j j� d|_ dS )zShutdown task consumer.zClosing consumer channel...N)r r r r �closer r r r �shutdown7 s zTasks.shutdownc C s d|j r|j jndiS )zReturn task consumer info.r zN/A)r �valuer r r r �info? s z Tasks.info) �__name__� __module__� __qualname__�__doc__r �requiresr r r r r! � __classcell__r r r r r s r N)r% Z kombu.commonr r Zceleryr Zcelery.utils.logr Zmingler �__all__r" �loggerr Z StartStopStepr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка