
    h"                         d Z ddlZddlmZmZ  ej
                  d      ej                  ed                      Zej                  e      ej                  d               Z	y)	zEThe ``celery list bindings`` command, used to inspect queue bindings.    N)CeleryCommandhandle_preload_optionslist)namec                      y)z^Get info from broker.

    Note:

        For RabbitMQ the management plugin is required.
    N )ctxs    K/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/list.pylist_r      s        )clsc                      j                   j                  }|j                         5 }|j                  j	                  |      j                          	 |j                  j                         } fd} |ddd        |ddd       |D ]  } ||d   |d   |d	           	 d
d
d
       y
# t        $ r t        j                  d      w xY w# 1 sw Y   y
xY w)zInspect queue bindings.z$Your transport cannot list bindings.c                 P    j                   j                  | dd|dd|        y )Nz<28 )objecho)qerr	   s      r
   fmtzbindings.<locals>.fmt!   s(    GGLLAc7!Ac7!A3/0r   QueueExchangezRouting Keyz----------------destinationsourcerouting_keyN)r   app
connectionamqpTaskConsumerdeclaremanagerget_bindingsNotImplementedErrorclick
UsageError)r	   r   connbindingsr   bs   `     r
   r'   r'      s    
 ''++C		 ATd#++-	K||002H	1GZ/Hh)A- !H+q/?@ A A
 # 	K""#IJJ	KA As#   *CB*-3C*C		CC)
__doc__r$   celery.bin.baser   r   grouppass_contextr   commandr'   r   r   r
   <module>r.      sr    K  A &    =!A  "Ar   