Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/worker/consumer/__pycache__/ |
a
��Sh�
� @ sx d Z ddlmZ ddlmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
d Ze e�ZejZG d
d � d ej�Zd S )
z Worker Task Consumer Bootstep.� )� annotations)�QoS�
ignore_errors)� bootsteps)�
get_logger)�detect_quorum_queues� )�Mingle)�Tasksc sT e Zd ZdZefZ� fdd�Zdd� Zdd� Zdd � Z d
d � Z
d d
�dd�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__� �F/usr/local/lib/python3.9/site-packages/celery/worker/consumer/tasks.pyr s zTasks.__init__c s^ � � � | �� ��� 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 �
qos_globalr r �set_prefetch_count, s �z'Tasks.start.<locals>.set_prefetch_countN)
Zupdate_strategiesr �
connectionZdefault_channelZ basic_qosZinitial_prefetch_count�appZamqpZ 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 �stop3 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 �shutdown9 s
zTasks.shutdownc C s d|j r|j jndiS )zReturn task consumer info.r zN/A)r �valuer r r r �infoA s z
Tasks.info�bool)�returnc C s@ |j j }|jjjr<t|j|j jj�\}}|r<d}t� d� |S )z�Determine if global QoS should be applied.
Additional information:
https://www.rabbitmq.com/docs/consumer-prefetch
https://www.rabbitmq.com/docs/quorum-queues#global-qos
Fz5Global QoS is disabled. Prefetch count in now static.)
r Zqos_semantics_matches_specr �confZworker_detect_quorum_queuesr � transportZ driver_type�loggerr% )r r r Zusing_quorum_queues�qnamer r r r E s
zTasks.qos_global)
�__name__�
__module__� __qualname__�__doc__r �requiresr r r! r# r% r �
__classcell__r r r r r
s r
N)r/ �
__future__r Z kombu.commonr r Zceleryr Zcelery.utils.logr Zcelery.utils.quorum_queuesr Zmingler �__all__r, r* r Z
StartStopStepr
r r r r �<module> s