o Df! @s*dZddlmZddlmZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZdd lmZdd lmZd4d d ZddZddZedZdededdfddZdefddZdedefddZeje dejdde e dd d!d"ejd#d$e e d d%d&ejd'd(e d)d d*d+ej!e d,d-Z"eje d.d)id/e#ded0ejdde e dd d!d"ejd#d$e e d d%d&ejd'd(e d)d d*d+ej!e d1d0Z$eje d.d)id/e#ded2ejdde e dd d!d"ejd#d$e e d d%d&ejd'd(e d)d d*d+ej!e d3d2Z%dS)5z@The ``celery control``, ``. inspect`` and ``. status`` programs.)partial)LiteralN)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!K/home/ubuntu/webapp/venv/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(  .r2cCsJtj|}i}|jr|ddt|||D|jr#||j|i|S)NcSsi|]\}}||qSr!r!).0kvr!r!r" /s z&_compile_arguments..)r r,r%updater2r')commandr%r, argumentsr!r!r"_compile_arguments+s   r:)inspectcontroltype_r8returncCs<t|}||vrd|}tjd|d|d|ddS)Nz, zCommand z not recognized. Available z commands: )message)_get_commands_of_typejoinr(r))r=r8choicescommand_listingr!r!r"_verify_command_name:s rDcs6dtjddffdd }tjddddd d|d S) Nrr>c s|sdSt}t}|d.g}|D]\}}|jr-|d|j}n|}|||jfq| |Wdn1sGwY|j j | dd| dS)Nz Commands F)nl)r@r( HelpFormattersection capitalizeitemsr+appendhelpwrite_dlrechogetvalueexit) rparamvaluerB formatter command_list command_nameinfocommand_previewr=r!r"callbackEs  z_list_option..callbackz--listTzList available z commands and exit.F)is_flagrL expose_valueis_eagerrY)r(Contextoption)r=rYr!rXr" _list_optionDs r_cs$fddtjD}tt|S)Ncs(g|]\}}|jkr|jr||fqSr!)typevisible)r3r0rVrXr!r" cs z)_get_commands_of_type..)r r,rJdictsorted)r=command_name_info_pairsr!rXr"r@bs  r@)clsz-tz --timeoutg?zRemote Control Optionsz%Timeout in seconds waiting for reply.)rfr`default help_grouprLz-dz --destinationz/Comma separated list of destination node names.)rfr`rhrLz-jz--jsonTzUse json as output format.)rfrZrhrLc Ks|rdntt|}|jjjj|||d}|stdtd|r(|j t |t |}| ddsB|j d |t|ddSdS) z%Show list of workers that are online.Ntimeout destinationrY'No nodes replied within time constraintr? exit_codequietF {} {} online.r)rr#rappr<r;pingr r rNrlengetr*r pluralize)rrjrkjsonkwargsrYr nodecountr!r!r"rjs(     rallow_extra_args)rfcontext_settingsr;c Kstd||r dntt|dd}t||j}|jjjj|||d}|j |fi|} | s2t dt d|r>|j t | dSt| } |jjsV|j d| t| d dSdS) z~Inspect the workers by sending them the COMMAND inspect command. Availability: RabbitMQ (AMQP) and Redis transports. r;NTrrirlrmrpr)rDrr#r:r%rrqr<r;_requestr r rNrrsror*r ru) rr8rjrkrvrwrYr9r;rrxr!r!r"r;s0      r<c Csxtd||r dntt|dd}|j}t||}|jjjj||||d|d}|s.t dt d|r:|j t |dSdS)zxSend the COMMAND control command to the workers. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports. r<NTr{)rjrkrYrr9rlrm) rDrr#r%r:rrqr< broadcastr r rNr) rr8rjrkrvrYr%r9rr!r!r"r<s(  )F)&__doc__ functoolsrtypingrr(kombu.utils.jsonrcelery.bin.baserrrrcelery.exceptionsr celery.platformsr celery.utilsr celery.worker.controlr r#r2r:_RemoteControlTypestrrDr_rcr@r8r^float pass_contextrargumentr;r<r!r!r!r"s