|
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/bin/__pycache__/ |
a
��Sh" � @ sX d Z ddlZddlmZmZ ejdd�ejedd� ���Zejed�ejd d
� ��Z dS )zEThe ``celery list bindings`` command, used to inspect queue bindings.� N)�
CeleryCommand�handle_preload_options�list)�namec C s dS )z^Get info from broker.
Note:
For RabbitMQ the management plugin is required.
N� ��ctxr r �9/usr/local/lib/python3.9/site-packages/celery/bin/list.py�list_ s r
)�clsc s� � j j}|�� ��}|j�|��� z|j�� }W n tyL t �
d��Y n0 � fdd�}|ddd� |ddd� |D ]}||d |d |d
� qvW d � n1 s�0 Y dS )zInspect queue bindings.z$Your transport cannot list bindings.c s$ � j �| d�d|d�d|� �� d S )Nz<28� )�objZecho)�q�e�rr r r �fmt! s zbindings.<locals>.fmt�QueueZExchangezRouting Keyz----------------�destination�sourceZrouting_keyN)r
�app�
connectionZamqpZTaskConsumerZdeclare�managerZget_bindings�NotImplementedError�clickZ
UsageError)r r �conn�bindingsr �br r r r s
r )
�__doc__r Zcelery.bin.baser r �groupZpass_contextr
�commandr r r r r �<module> s