h! PdZddlmZddlmZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZdd lmZdd lmZd,d Zd Zd ZedZdededdfdZdefdZdedefdZej<e ej>dde e dddej>dde e ddej>d d!e d"dd#$ejBe d%Z"ej<e d&d"i'ejFded(ej>dde e dddej>dde e ddej>d d!e d"dd#$ejBe d)Z$ej<e d&d"i'ejFded*ej>dde e dddej>dde e ddej>d d!e d"dd#$ejBe d+Z%y)-z@The ``celery control``, ``. inspect`` and ``. status`` programs.)partial)LiteralN)dumps)COMMA_SEPARATED_LIST CeleryCommand CeleryOptionhandle_preload_options)CeleryCommandException)EX_UNAVAILABLE)text)Panelc*tt|}||}|jj|ddd}|jj |\}}|jj d|||rt j|dnd|y) Nz: cyanT)fgboldz->) show_body)nextiterobjstyleprettysay_chatr indent)ctxreplies show_replynodereplystatuspreplys N/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/bin/control.py_say_remote_command_replyr$s W D DME 77==D6d= ;DWW^^E*NFFGGTdVF8,/9T[[+r)+c#>Kd} t|D](\}} |j|\}}||||n|f*||d|ddy#t$r?|jrY!t j dj ||jwxYw#||d|ddwxYww)Nrz Command {!r} takes arguments: {}) enumerateargs IndexErrorvariadicclick UsageErrorformat signature)metamethodr(iargnametyps r#_consume_argumentsr5s A oFAs A IIaL cCHS@@&qr(Q 1==&&6==011 1qr(Qs=BBAB BB B0B  B BBctj|}i}|jr0|jt |||Dcic]\}}|| c}}|j r|j|j |i|Scc}}wN)r r/r(updater5r*)commandr(r/ argumentskvs r#_compile_argumentsr=+sy ::g DI yy/gtD QAqD   }}$--./   s A= )inspectcontroltype_r9returnct|}||vr0dj|}tjd|d|d|y)Nz, zCommand z not recognized. Available z commands: )message)_get_commands_of_typejoinr+r,)r@r9choicescommand_listings r#_verify_command_namerH:sS#E*Gg))G,wi'B5'UdTef  r%crdtjddffd }tjdddddd| S) NrrAc|syt }tj}|j j d5g}|j D]B\}}|j r|d|j }n|}|j||jfD|j|ddd|jj|jd|jy#1swYExYw)Nz Commands F)nl)rDr+ HelpFormattersection capitalizeitemsr.appendhelpwrite_dlrechogetvalueexit) rparamvaluerF formatter command_list command_nameinfocommand_previewr@s r#callbackz_list_option..callbackEs '.'')   %"2"2"4!5Y? @ -L&-mmo" d>>)5a7G&HO&2O##_dii$@A '6   | , -  Y'')e 4   - -s A)C33C<z--listTzList available z commands and exit.F)is_flagrR expose_valueis_eagerr^)r+Contextoption)r@r^s` r# _list_optionrdDsIemmd& <<ug%8 9  r%ctjjDcgc]$\}}|j|k(r|jr||f&}}}t t |Scc}}wr7)r r/rPtypevisibledictsorted)r@r3r\command_name_info_pairss r#rDrDbs_',zz'7'7'9#t 99 $,, t  ./ 00 s)A")clsz-tz --timeoutg?zRemote Control Optionsz%Timeout in seconds waiting for reply.)rkrfdefault help_grouprRz-dz --destinationz/Comma separated list of destination node names.)rkrfrmrRz-jz--jsonTzUse json as output format.)rkr_rmrRc |rdntt|}|jjjj |||j }|stdt|r$|jjt|t|}|jdds@|jjdj|tj|dyy) z%Show list of workers that are online.Ntimeout destinationr^'No nodes replied within time constraintrC exit_codequietF {} {} online.r)rr$rappr?r>pingr r rTrlengetr-r pluralize)rrprqjsonkwargsr^r nodecounts r#r!r!js0t)BC!HHggkk!!))'6A3;*==ATV  $=$     U7^$G I ::gu %  &-- t~~i8: ; &r%allow_extra_args)rkcontext_settingsr>c 4td||rdntt|d}t||j}|j j jj|||}|j|fi|} | stdt|r%|j jt| yt| } |j js@|j jdj!| t#j$| d yy) z~Inspect the workers by sending them the COMMAND inspect command. Availability: RabbitMQ (AMQP) and Redis transports. r>NTrrorrrsrvr)rHrr$r=r(rrwr?r>_requestr r rTrryrur-r r{) rr9rprqr|r}r^r:r>rr~s r#r>r>s<G,t)BC48":H"7CHH5Iggkk!!))'6A3;*=Ggw4)4G $=$     U7^$G I 77==  &-- t~~i8: ; r%r?cVtd||rdntt|d}|j}t ||}|j j jj||||d|}|stdt|r%|j jt|yy)zxSend the COMMAND control command to the workers. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports. r?NTr)rprqr^r r:rrrs) rHrr$r(r=rrwr? broadcastr r rTr) rr9rprqr|r^r(r:rs r#r?r?s<G,t)BC48":H 88D"7D1Iggkk!!++GW8C5=266? ,AG $=$     U7^$ r%)F)&__doc__ functoolsrtypingrr+kombu.utils.jsonrcelery.bin.baserrrr celery.exceptionsr celery.platformsr celery.utilsr celery.worker.controlr r$r5r=_RemoteControlTypestrrHrdrhrDr9rcfloat pass_contextr!argumentr>r?r%r#rsF "ee4+'+$ 12 2 S T *<1!311=! d1: <d'1D F d1/ 1 ; 1 F<",;*=!3T :<  i d1: <d'1D F d1/ 1 ; 1 F<<2;<=!3T :<  i d1: <d'1D F d1/ 1 % 1 F<<2%r%