U d @sdZddlmZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZddlmZdd lmZd.d d Zd dZddZejedejdde eddddejdde edddejdde dddd eje d!d"Zejed#did$ejd%ed&d'ejDd(ejdde eddddejdde edddejdde dddd eje d)d*Zejed#did$ejd%ed+d'ejDd(ejdde eddddejdde edddejdde dddd eje d,d-Z dS)/z@The ``celery control``, ``. inspect`` and ``. status`` programs.)partialN)dumps)COMMA_SEPARATED_LIST CeleryCommand CeleryOptionhandle_preload_options)CeleryCommandException)EX_UNAVAILABLE)text)PanelFcCsltt|}||}|jj|dddd}|j|\}}|jjd|||r^t|dnd|ddS) Nz: ZcyanT)ZfgZboldz->)Z show_body)nextiterobjstyleprettyZsay_chatr indent)ctxreplies show_replynodereplystatusZpreplyr6/tmp/pip-unpacked-wheel-9cz4377o/celery/bin/control.py_say_remote_command_replys rc csd}zxt|D]j\}}z|j|\}}Wn4tk r\|jrDYqztd||jYqX||dk rp||n|fVqW5||d|dd<XdS)Nrz Command {!r} takes arguments: {}) enumerateargs IndexErrorvariadicclickZ UsageErrorformat signature)metamethodriargnametyprrr_consume_argumentss   r*cCsJtj|}i}|jr0|ddt|||D|jrF||j|i|S)NcSsi|]\}}||qSrr).0kvrrr /sz&_compile_arguments..)r r$rupdater*r )actionrr$ argumentsrrr_compile_arguments+s   r2)clsz-tz --timeoutg?zRemote Control Optionsz%Timeout in seconds waiting for reply.)r3typedefault help_grouphelpz-dz --destinationz/Comma separated list of destination node names.)r3r4r6r7z-jz--jsonTzUse json as output format.)r3Zis_flagr6r7c Ks|rdntt|}|jjjj|||d}|sds rN)r4c Ks|rdn tt|dd}t||j}|jjjj|||d}|j|f|} | sVt dt d|rn|j t | dSt | } |jjs|j d| t| ddS) z\Inspect the worker at runtime. Availability: RabbitMQ (AMQP) and Redis transports. NTrr8r<r=r@r)rrr2rrrArBrC_requestrr rDrrEr?r"r rG) rr0r9r:rHrIr;r1rCrrJrrrrCbs2     rCcCs$g|]\}}|jdkr|jr|qS)rBrKrLrrrrNs c Csj|rdn tt|dd}|j}t||}|jjjj||||d|d}|sRtdt d|rf|j t |dS)z_Workers remote control. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports. NTrO)r9r:r;rr1r<r=) rrrr2rrArB broadcastrr rDr) rr0r9r:rHr;rr1rrrrrBs$  rB)F)!__doc__ functoolsrr!Zkombu.utils.jsonrZcelery.bin.baserrrrZcelery.exceptionsrZcelery.platformsr Z celery.utilsr Zcelery.worker.controlr rr*r2commandoptionfloatZ pass_contextrargumentZChoicer$itemsrCrBrrrrs