Yohohohohohooho | Sanrei Aya
Sanrei Aya


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/utils/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/utils/__pycache__/quorum_queues.cpython-39.pyc
a

��Sh��@s ddlmZddd�dd�ZdS)�)�annotations�strztuple[bool, str])�driver_type�returncCsJ|dk}|rF|jj}|D],}||jp(i}|�d�dkrd|fSqdS)aDetect if any of the queues are quorum queues.

    Returns:
        tuple[bool, str]: A tuple containing a boolean indicating if any of the queues are quorum queues
        and the name of the first quorum queue found or an empty string if no quorum queues were found.
    �amqpzx-queue-typeZquorumT)F�)r�queuesZqueue_arguments�get)ZapprZis_rabbitmq_brokerr�qnameZ
qarguments�r�D/usr/local/lib/python3.9/site-packages/celery/utils/quorum_queues.py�detect_quorum_queuessr
N)�
__future__rr
rrrr�<module>s

Yohohohohohooho | Sanrei Aya