o h @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: cyanT)fgboldz->) show_body)nextiterobjstyleprettysay_chatr indent)ctxreplies show_replynodereplystatuspreplyr D/var/www/html/env/lib/python3.10/site-packages/celery/bin/control.py_say_remote_command_replys  r"c csd}zQt|D]2\}}z |j|\}}Wnty,|jr"Yn&td||jw||dur6||n|fVqW||d|dd<dSW||d|dd<dS||d|dd<w)Nrz Command {!r} takes arguments: {}) enumerateargs IndexErrorvariadicclick UsageErrorformat signature)metamethodr$iargnametypr r r!_consume_argumentss(  .r1cCsJtj|}i}|jr|ddt|||D|jr#||j|i|S)NcSsi|]\}}||qSr r ).0kvr r r! .s z&_compile_arguments..)r r+r$updater1r&)actionr$r+ argumentsr r r!_compile_arguments*s   r9)clsz-tz --timeoutg?zRemote Control Optionsz%Timeout in seconds waiting for reply.)r:typedefault help_grouphelpz-dz --destinationz/Comma separated list of destination node names.)r:r;r=r>z-jz--jsonTzUse json as output format.)r:is_flagr=r>c Ks|rdntt|}|jjjj|||d}|stdtd|r(|j t |t |}| ddsB|j d |t|ddSdS) z%Show list of workers that are online.Ntimeout destinationcallback'No nodes replied within time constraintmessage exit_codequietF {} {} online.r)rr"rappcontrolinspectpingrr echorlengetr)r pluralize)rrArBjsonkwargsrCr nodecountr r r!r6s(     rallow_extra_args)r:context_settingsr7cC$g|]\}}|jdkr|jr|qS)rLr;visibler2r/infor r r! c r\)r;c Ks|rdntt|dd}t||j}|jjjj|||d}|j|fi|} | s-t dt d|r9|j t | dSt | } |jjsQ|j d| t| ddSdS) z\Inspect the worker at runtime. Availability: RabbitMQ (AMQP) and Redis transports. NTrr@rDrErIr)rr"r9r$rrJrKrL_requestrr rNrrOrHr)r rQ) rr7rArBrRrSrCr8rLrrTr r r!rLas2       rLcCrW)rKrXrZr r r!r\r]c Csn|rdntt|dd}|j}t||}|jjjj||||d|d}|s)tdt d|r5|j t |dSdS)z_Workers remote control. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports. NTr^)rArBrCrr8rDrE) rr"r$r9rrJrK broadcastrr rNr) rr7rArBrRrCr$r8rr r r!rKs&  rK)F)!__doc__ functoolsrr'kombu.utils.jsonrcelery.bin.baserrrrcelery.exceptionsrcelery.platformsr celery.utilsr celery.worker.controlr r"r1r9commandoptionfloat pass_contextrargumentChoicer+itemsrLrKr r r r!s