`fMTdZddlZddlZddlmZmZmZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZmZdd lmZd d lmZd dlmZdZdZee Z!edgdZ"dZ#dZ$GddeZ%dZ&dZ'e'dZ(e'dddefgdvdZ)d Z*e'd!d"#d$Z+ej,j-fd%Z.ej/j0ej1j0fd&Z2e&d'd"#dwd(Z3e&d)d*#dwd+Z4dwd,Z5e&d'd-e6fgd./d0Z7e&d1e6fd2e6fgd34d5Z8e&d1e6fd6e9fd7e9fgd84dxd9Z:e'd:Z;e&dyd;Z<e&d<Z=e&d=Z>e&d>Z?e'd?dyd@Z@e'dABdCZAe'dDZBe'dEFdGZCdHZDe'dIFdJZEe'dKFdvdLZFe'dMFdNZGe'dOdPdQRdzdSZHe'dTdUe6fdVeIfdWeIfgdXYd{d]ZJe'd^ZKe'd_eIfgd`4d|daZLe&dbeIfgdc4d}ddZMe&dbeIfgdc4d}deZNe&d~dfZOe&dgeIfdheIfgdi4ddjZPe&ddlZQe&dme6fdne6fdoe6fdpe6fgdq4 dxdrZRe&dme6fgds4dtZSe'duZTdS)z.Worker remote control command implementations.N)UserDict defaultdict namedtuple) TERM_SIGNAME) safe_repr)WorkerShutdown)signals) maybe_list) get_logger)jsonify strtobool)ratestate)Request)Panel)exchange routing_key rate_limitcontroller_info_t)aliastypevisibledefault_timeouthelp signatureargsvariadicc d|iS)Nokvalues G/var/www/html/env/lib/python3.11/site-packages/celery/worker/control.pyr!r!s %=c d|iS)Nerrorr"r#s r%nokr)"s U r&cNeZdZdZiZiZedZe ddZdS) rz+Global registry of remote control commands.c@|r|jdi||S|jdi|S)Nr") _register)clsrkwargss r%registerzPanel.register,sA  2*=3=**6**D1 1s}&&v&&&r&NcontrolT?c 6  f d} | S)Nc  p|j}p3|jpddd}|j|<t  |  j|<r |j<|S)N r)__name____doc__stripsplitdatarmeta) fun control_name_helprrr-rrnamerrrrs r%_innerzPanel._register.._inner7s/36:[r&rc (tjdddi|S)Nrr0r"rr/r.s r%control_commandrGD > 3 3y 3F 3 33r&c (tjdddi|S)Nrinspectr"rErFs r%inspect_commandrKHrHr&cNt|jS)z6Information about Celery installation for bug reports.)r!app bugreportrs r%reportrONs  ei!!## $ $$r& dump_confz[include_defaults=False] with_defaults)rrrFc vt|jj|tt S)zList configuration.)rQ) keyfilterunknown_type_filter)r rMconftable_wanted_config_keyr)rrQr.s r%rUrUTs8 59>''m'DD/'0 2 2 22r&cXt|to|d S)N__) isinstancestr startswith)keys r%rWrW`s& c3   <t(<(<$<zquery_task..lsA     $$chhjj1   r&)_find_requests_by_idr )rr^r.s r% query_taskrhfs1   ' 388   r&c#PK|D] } ||V#t$rYwxYwdSN)KeyError)r^ get_requesttask_ids r%rgrgrs] +g&& & & & &    D s  ##c:||rdS||rdSdS)Nactivereservedreadyr")request is_active is_reserveds r%rbrb{s7yx W  z 7r&rmc tt|pgd}}t||||fi|}t|trd|vr|St d|dS)zRevoke task by task id (or list of ids). Keyword Arguments: terminate (bool): Also terminate the process if the task is active. signal (str): Name of signal to use for terminate (e.g., ``KILL``). Nr!ztasks z flagged as revoked)setr _revokerZdictr!)rrm terminatesignalr.task_idss r%revoker|sxJw//5266gHuh 6DDVDDH(D!!dh&6&6 4x444 5 55r&headersz/[key1=value1 [key2=value2 [... [keyN=valueN]]]]c tj|pt}t|tr d|D}|D]_\}}t tj |pgt t |z}|tj|<`|std|dSt tj } tt} | D]} t| dr| jr|D]\} } | | jvrt | } t | j| }t|t| z}|r<| | || |jj|| std|dStd| dS)aRevoke task by header (or list of headers). Keyword Arguments: headers(dictionary): Dictionary that contains stamping scheme name as keys and stamps as values. If headers is a list, it will be converted to a dictionary. terminate (bool): Also terminate the process if the task is active. signal (str): Name of signal to use for terminate (e.g., ``KILL``). Sample headers input: {'mtask_id': [id1, id2, id3]} cxi|]7}|dd|dd8S)=rr)r9)rdhs r%rfz-revoke_by_stamped_headers..s6EEE1773<<?AGGCLLOEEEr&zheaders z' flagged as revoked, but not terminatedstampsrzz were not terminatedz revoked)_signalssignumrrZlistitemsr worker_staterevoked_stampsgetr!active_requestsrrvhasattrrupdateryconsumerpool)rr}ryrzr.rheaderrupdated_stampsr#terminated_scheme_to_stamps_mappingreexpected_header_keyexpected_header_value actual_headermatching_stamps_for_requests r%revoke_by_stamped_headersrs&_V3| 4 4F'4  FEEWEEE!--//==#L$?$C$CF$K$K$QrRRUYZdekZlZlUmUmm.< #F++ OMWMMMNNN<788O*5c*:*:'  J J 3 ! ! Jcj J>Emmoo J J:#%:&#*44,67L,M,M)$.sz:M/N$O$OM25m2D2DsK`GaGa2a/2J;)>??@@@ IIh  E KK.666 Or&rzz [id1 [id2 [... [idN]]]])rrrc (t||d|S)z+Terminate task by task id (or list of ids).T)ryrz)r|)rrzrmr.s r%ryrys %D @ @ @@r& task_namerz0 )rrc  t|n)#t$r}td|cYd}~Sd}~wwxYw ||jj|_n<#t $r/td|dtdcYSwxYw|j |s*t d|tdSt d ||td S) zTell worker(s) to modify the rate limit for a task by type. See Also: :attr:`celery.app.task.Task.rate_limit`. Arguments: task_name (str): Type of task to set rate limit for. rate_limit (int, str): New rate limit. zInvalid rate limit string: Nz&Rate limit attempt for unknown task %sTexc_info unknown taskz)Rate limits disabled for tasks of type %sz rate limit disabled successfullyz(New rate limit for tasks of type %s: %s.znew rate limit set successfully) r ValueErrorr)rMtasksrrkrr(rreset_rate_limitsrcr!)rrrr.excs r%rrs7": Z :::88899999999:#0:  "-- ### =  / / />"""""#  N$$&&& 6 ?KKK4555 KK::''' / 0 00s% 8388A6B  B softhardz# [hard_secs]c  |jj|}n<#t$r/td|dt dcYSwxYw||_||_td|||tdS)zTell worker(s) to modify the time limit for task by type. Arguments: task_name (str): Name of task to change. hard (float): Hard time limit. soft (float): Soft time limit. z-Change time limit attempt for unknown task %sTrrz5New time limits for tasks of type %s: soft=%s hard=%sztime limits set successfully) rMrrkrr(r)soft_time_limit time_limitrcr!)rrrrr.tasks r%rrs#yy) ### D  / / />"""""#  DDO KKG4''' , - --s6A Ac (d|jjjiS)z Get current logical clock value.clock)rMrr$rr.s r%rr=s UY_* ++r&c d|jjr#|jj|||dSdS)zHold election. Arguments: id (str): Unique election id. topic (str): Election topic. action (str): Action to take for elected actor. N)rgossipelection)rratopicactionr.s r%rrCs> ~: &&r5&99999::r&c|jj}|jrLd|jvrC|jdtdt dSt dS)z+Tell worker(s) to send task-related events.rz)Events of group {task} enabled by remote.ztask events enabledztask events already enabled)revent_dispatchergroupsrrrcr!r dispatchers r% enable_eventsrPsn0J)V:+<<<f%%% ?@@@'((( + , ,,r&c|jj}d|jvrC|jdtdt dSt dS)z3Tell worker(s) to stop sending task-related events.rz*Events of group {task} disabled by remote.ztask events disabledztask events already disabled)rrrdiscardrrcr!rs r%disable_eventsr[sd0J """!!&))) @AAA())) , - --r&ctd|jj}|jdddit jdS)z3Tell worker(s) to send event heartbeat immediately.zHeartbeat requested by remote.worker-heartbeatfreqN)r)rdebugrrsendr SOFTWARE_INFOrs r% heartbeatrfsG LL12220JJOMMQM,2LMMMMMr&)rc 0||jkrtd||rtj|tjtjj|jj dSdS)zRequest mingle sync-data.z sync with %s)rrN) hostnamerrcrrrpurge_datarMrforward)r from_noderr.s r%hellorps EN"" NI...  1  ' ' 0 0 0""$$$#+1Y_,,..   #"r&g?)rc tdS)zPing worker(s).pong)r!rs r%pingrs f::r&c >|jjS)z&Request worker statistics/information.)r controllerstatsrs r%rrs > $ * * , ,,r& dump_schedule)rc Ntt|jjS)z0List of currently scheduled ETA/countdown tasks.)r_iter_schedule_requestsrtimerrs r% scheduledrs  '(<== > >>r&c#$K|jjD]} |jjd}t |t r?|jr|jnd|j| dVj#ttf$rY}wxYwdS)Nr)etapriorityrr) schedulequeueentryrrZrr isoformatrrc IndexError TypeError)rwaitingarg0s r%rrs>'   =%a(D$(( 378E48--/// ' 0#yy{{ I&    H   sA99B  B  dump_reservedc |tj|tjz }|sgSd|DS)zAList of currently reserved tasks, not including scheduled/active.c6g|]}|Sr"rc)rdrrs r% zreserved..s 9 9 9wGLLNN 9 9 9r&)tsetrreserved_requestsr)rr.reserved_taskss r%rprpsU  <122 </00 1  9 9. 9 9 99r& dump_activec Zfd|tjDS)z'List of tasks currently being executed.c<g|]}|S))safer)rdrrrs r%rzactive..s= E E E LLdL # # E E Er&)rrr)rrr.s ` r%rorosE E E E E ::l&BCC E E EEr& dump_revokedc 4ttjS)zList of revoked task-ids.)rrrrs r%rrs  $ % %%r& dump_tasks taskinfoitemsz[attr1 [attr2 [... [attrN]]]])rrrc |jjpt|rn dD}fdfdt|DS)zList of registered tasks. Arguments: taskinfoitems (Sequence[str]): List of task attributes to include. Defaults to ``exchange,routing_key,rate_limit``. builtins (bool): Also include built-in tasks. c3DK|]}|d|VdS)zcelery.N)r\)rdrs r% zregistered..sP"@"@DOOI$>$>"@ "@"@"@"@"@"@r&cfdD}|rLd|D}djd|SjS)Nc pi|]2}t|d|tt|d3Srj)getattrr[)rdfieldrs r%rfz5registered.._extract_info..sK   7<tUD))5 3wtUD1122555r&c8g|]}d|S)r)r)rdfs r%rz5registered.._extract_info..s"888ACHHQKK888r&z{} [{}] )rrr?r)rfieldsrcrs` r% _extract_infoz!registered.._extract_infos{    @M     ?88888D##DIsxx~~>> >yr&c2g|]}|Sr"r")rdrrregs r%rzregistered..s' ? ? ?MM#d) $ $ ? ? ?r&)rMrDEFAULT_TASK_INFO_ITEMSsorted)rrbuiltinsr.rrrs ` @@r% registeredr s )/C!<%zobjgraph..s Q'\r&)r  highlightfilenamer) objgraph ImportErrorrrctempfileNamedTemporaryFileby_type show_backrefsr?)rr r r _objgraphfhrs @r%rrs6;$$$$$ ;;;9:::; KK+T222  $G,25 B B B%EG##D))$3$/ +A+A+A+AW    BG$%%%%%%%%%%%%%%%%%%s"AB++B/2B/c "ddlm}|S)z Sample current RSS memory usage.r) sample_mem)celery.utils.debugr")rr.r"s r% memsampler$s".----- :<<r&samplesz[n_samples=10]c ddlm}tj}|||S)z/Dump statistics of previous memsample requests.r)r)file) celery.utilsrioStringIOmemdumpgetvalue)rr%r.routs r%r+r+sC #""""" +--C MMsM <<>>r&nz[N=1]c |jjjrtdS|jj||j|tdS)z!Grow pool by n processes/threads.zJpool_grow is not supported with autoscale. Adjust autoscale range instead.zpool will grow)rr autoscalerr)rgrow_update_prefetch_countr!rr.r.s r% pool_growr4sa  ~ +1_```   ### --a000   r&c |jjjrtdS|jj||j| tdS)z#Shrink pool by n processes/threads.zLpool_shrink is not supported with autoscale. Adjust autoscale range instead.zpool will shrink)rrr0r)rshrinkr2r!r3s r% pool_shrinkr7sc  ~ +2abbb ""1%%% --qb111  ! !!r&c |jjjr1|jj|||t dStd)zRestart execution pool.)reloaderzreload startedzPool restarts not enabled)rMrUworker_pool_restartsrrreloadr!r)rmodulesr;r9r.s r% pool_restartr=,sQ y~*6 !((&8(LLL"###4555r&maxminz [max [min]]c|jjj}|r.|||\}}t d|d|St d)zModify autoscale settings.zautoscale now max=z min=zAutoscale not enabled)rrr0rr!r)rr>r?r0max_min_s r% autoscalerC6s` *5J:&&sC00 d8t88$88999 , - --r&Got shutdown from remotec Tt|td)zShutdown worker(s).r)rwarningr)rmsgr.s r%shutdownrHCs$ NN3   r&rr exchange_typerz' [exchange [type [routing_key]]]c l|jj|jj|||pd|fi|td|S)z2Tell worker(s) to consume from task queue by name.directz add consumer )r call_soonadd_task_queuer!)rrrrIroptionss r% add_consumerrOLs^EN % x2(KLLCJLLL %e%% & &&r&zc p|j|jj|td|S)z9Tell worker(s) to stop consuming from task queue by name.zno longer consuming from )rrLcancel_task_queuer!)rr_s r%cancel_consumerrS^sA  N (% 1%11 2 22r&cT|jjrd|jjjDSgS)z:List the task queues a worker is currently consuming from.cTg|]%}t|d&S)T)recurse)rxas_dict)rdrs r%rz!active_queues..nsDBBBU]]4]0011BBBr&)r task_consumerqueuesrs r% active_queuesrZjsF ~#BBB"^9@BBB B Ir&)F)FN)NNNrj)NF)r r r)r )r)NFN)NN)rD)Ur7r)r collectionsrrrbilliard.commonrkombu.utils.encodingrcelery.exceptionsrcelery.platformsr rcelery.utils.functionalr celery.utils.logr celery.utils.serializationr r celery.utils.timerr4rrrrr__all__rr6rrr!r)rrGrKrOrUrWrhrequests __getitem__rgr __contains__rrbr|rrwr[ryrfloatrrrrrrrrrrrrprorr intrr$r+r4r7r=rCrHrOrSrZr"r&r%rjs44 9999999999((((((******,,,,,,000000......''''''99999999""""""###### C H  J2555 H<444444 %%%  ( I & ' 222  2===  ' &2%:%F*9F+=J '666 6$ ?3H3H3H 3Hl0  S/ 0 AA  A   |S1 2@!1!1 !1H  vuo ?3... .4,,,  : : : :---...NNN     "%%%&% --- '''??('?   '''::(':}%%%EEE&%E ~&&&&&'&&   - @@@  @: 3-% S'9 :> %%%  %0  c    *     *""" "6666 #, %... . # S #    8=A!'''' C. 33 3r&