o
    h                     @  s   d dl mZ d	ddZdS )
    )annotationsdriver_typestrreturntuple[bool, str]c                 C  sJ   |dk}|r#| j j}|D ]}|| jpi }|ddkr"d|f  S qdS )a  Detect 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-typequorumT)F )r   queuesqueue_argumentsget)appr   is_rabbitmq_brokerr
   qname
qarguments r   \/var/www/html/optinet_system/venv/lib/python3.10/site-packages/celery/utils/quorum_queues.pydetect_quorum_queues   s   r   N)r   r   r   r   )
__future__r   r   r   r   r   r   <module>   s    