a xdA@sdZddlZddlZddlmZmZddlmZddlm Z ddl m Z ddl m ZddlmZdd lmZdd lmZmZdd lmZd d lmZd dlmZdZdZeeZ edgdZ!ddZ"ddZ#GdddeZ$ddZ%ddZ&e&ddZ'e&dd d!efgd"dd$d%Z(d&d'Z)e&d(d)d*d+d,Z*ej+j,fd-d.Z-ej.j/ej0j/fd/d0Z1e%d1d)d*dd2d3Z2e%d1d4e3fgd5d6d7d8Z4e%d9e3fd:e3fgd;d<d=d:Z5e%d9e3fd>e6fd?e6fgd@d<ddAdBZ7e&dCdDZ8e%ddEdFZ9e%dGdHZ:e%dIdJZ;e%dKdLZe&dTdUZ?e&dVdWdXdYZ@dZd[ZAe&d\dWd]d^ZBe&d_dWd`daZCe&dbdWdcddZDe&dedfdgdhddidjZEe&dkdle3fdmeFfdneFfgdodpddtduZGe&dvdwZHe&dxeFfgdyd<ddzd{ZIe%d|eFfgd}d<dd~dZJe%d|eFfgd}d<dddZKe%dddZLe%deFfdeFfgdd<dddZMe%dddZNe%de3fde3fde3fde3fgdd<dddZOe%de3fgdd<ddZPe&ddZQdS)z.Worker remote control command implementations.N)UserDict 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 signatureargsvariadiccCsd|iS)NokvaluerrM/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/worker/control.pyrsrcCsd|iS)Nerrorrr rrr"nok"sr$c @s2eZdZdZiZiZeddZed dd ZdS) rz+Global registry of remote control commands.cOs(|r|jfi||S|jfi|SN) _register)clsrkwargsrrr"register,szPanel.registerNcontrolT?c s" f dd} | S)Nc s^p|j}p$|jpddd}|j|<t |j|<rZ|j<|S)N r)__name____doc__stripsplitdatarmeta)ZfunZ control_nameZ_help rrr'rrnamerrrrrr"_inner7s    zPanel._register.._innerr) r'r5rrrrrrrrr6rr4r"r&2s zPanel._register) NNr*Tr+NNNN) r. __module__ __qualname__r/r2r3 classmethodr)r&rrrr"r&s rcKstjfddi|S)Nrr*rr)r(rrr"control_commandDsr<cKstjfddi|S)Nrinspectr:r;rrr"inspect_commandHsr>cCst|jS)z6Information about Celery installation for bug reports.)rappZ bugreportrrrr"reportNsr@Z dump_confz[include_defaults=False] with_defaults)rrrFcKst|jjj|dttdS)zList configuration.)rA)Z keyfilterZunknown_type_filter)r r?conftable_wanted_config_keyr)rrAr(rrr"rBTsrBcCst|to|d S)N__) isinstancestr startswith)keyrrr"rD`srDidsz[id1 [id2 [... [idN]]]])rrcKsddtt|DS)z!Query for task information by id.cSs i|]}|jt||fqSr)id_state_of_taskinfo).0reqrrr" lszquery_task..)_find_requests_by_idr)rrJr(rrr" query_taskfs rRc cs0|D]&}z||VWqty(Yq0qdSr%)KeyError)rJ get_requesttask_idrrr"rQrs  rQcCs||r dS||rdSdS)Nactivereservedreadyr)requestZ is_active is_reservedrrr"rL{s rLrUc Kstt|p gd}}t|}t}tj||rt|p>t}t |D]L} | j |vrJ| | j t d| j || j|jj|dt||krJqqJ|stdStdd|Sd|} t d| td| d S) 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``). NzTerminating %s (%s))signalzterminate: tasks unknownz terminate: {}z, zTasks flagged as revoked: %sztasks z flagged as revoked)setrlen worker_staterevokedupdate_signalssignumrrQrKaddloggerrM terminateconsumerpoolrformatjoin) rrUrer[r(Ztask_idssizeZ terminatedrbrYZidstrrrr"revokes&       rkr[z [id1 [id2 [... [idN]]]])rrrcKst||d|dS)z+Terminate task by task id (or list of ids).T)rer[)rk)rr[rUr(rrr"resre task_namerz0 )rrc Ksz t|Wn2ty>}ztd|WYd}~Sd}~00z||jj|_Wn*ty|tjd|ddtdYS0|j |st d|t dSt d ||t d S) zTell worker(s) to modify the rate limit for a task by type. See Also: :attr:`celery.task.base.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$r?tasksrrSrdr#rfZreset_rate_limitsrMr)rrlrr(excrrr"rs& $   softhardz# [hard_secs]cKs`z|jj|}Wn*ty:tjd|ddtdYS0||_||_td|||t dS)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 %sTrmroz5New time limits for tasks of type %s: soft=%s hard=%sztime limits set successfully) r?rqrSrdr#r$Zsoft_time_limit time_limitrMr)rrlrtrsr(taskrrr"rus  rucKsd|jjjiS)z Get current logical clock value.clock)r?rwr!rr(rrr"rwsrwcKs|jjr|jj|||dS)zHold election. Arguments: id (str): Unique election id. topic (str): Election topic. action (str): Action to take for elected actor. N)rfZgossipelection)rrKZtopicactionr(rrr"rys rycCs>|jj}|jr6d|jvr6|jdtdtdStdS)z+Tell worker(s) to send task-related events.rvz)Events of group {task} enabled by remote.ztask events enabledztask events already enabled)rfevent_dispatchergroupsrcrdrMrr dispatcherrrr" enable_eventss   rcCs8|jj}d|jvr0|jdtdtdStdS)z3Tell worker(s) to stop sending task-related events.rvz*Events of group {task} disabled by remote.ztask events disabledztask events already disabled)rfr{r|discardrdrMrr}rrr"disable_eventss    rcCs,td|jj}|jddditjdS)z3Tell worker(s) to send event heartbeat immediately.zHeartbeat requested by remote.worker-heartbeatfreqN)r)rddebugrfr{sendr^Z SOFTWARE_INFOr}rrr" heartbeat%s r)rcKs@||jkrizreserved..)tsetr^reserved_requestsactive_requests)rr(Zreserved_tasksrrr"rW`s  rWZ dump_activecKsdd|tjDS)z'List of tasks currently being executed.cSsg|] }|qSrrrrrr"roszactive..)rr^rrxrrr"rVls rVZ dump_revokedcKs ttjS)zList of revoked task-ids.)rr^r_rxrrr"r_ssr_Z dump_tasks taskinfoitemsz[attr1 [attr2 [... [attrN]]]])rrrc sJ|jjpt|rn ddD}fddfddt|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. css|]}|ds|VqdS)zcelery.N)rHrNrvrrr" szregistered..csBfddD}|r._extract_info..cSsg|]}d|qS)=)ri)rNfrrr"rrz5registered.._extract_info..z{} [{}] )itemsrhr5ri)rvfieldsrM)rrr" _extract_infos z!registered.._extract_infocsg|]}|qSrrr)rregrr"rrzregistered..)r?rqDEFAULT_TASK_INFO_ITEMSsorted)rrbuiltinsr(rqr)rrrr" registeredys  rgN@rnum max_depthz.[object_type=Request] [num=200 [max_depth=10]])rrr rcsz ddl}Wnty&tdYn0td|tjddddH}||d||j|fd d |jd d |jiWdS1s0YdS) aCreate graph of uncollected objects (memory-leak debugging). Arguments: num (int): Max number of objects to graph. max_depth (int): Traverse at most n levels deep. type (str): Name of object to graph. Default is ``"Request"``. rNzRequires the objgraph libraryzDumping graph for type %rZcobjgz.pngF)prefixsuffixdeletecs|vSr%r)vZobjectsrr"rzobjgraph..)rZ highlightfilenamer) objgraph ImportErrorrdrMtempfileNamedTemporaryFileZby_typeZ show_backrefsr5)rrrrZ _objgraphfhrrr"rs     rcKsddlm}|S)z Sample current RSS memory usage.r) sample_mem)Zcelery.utils.debugr)rr(rrrr" memsamples rsamplesz[n_samples=10]cKs(ddlm}t}|j|d|S)z/Dump statistics of previous memsample requests.r)r)file)Z celery.utilsrioStringIOmemdumpgetvalue)rrr(routrrr"rs  rnz[N=1]cKs4|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)rfr autoscalerr$rgZgrow_update_prefetch_countrrrr(rrr" pool_grows   rcKs6|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)rfrrr$rgshrinkrrrrrr" pool_shrinks  rcKs2|jjjr&|jjj|||dtdStddS)zRestart execution pool.)reloaderzreload startedzPool restarts not enabledN)r?rBZworker_pool_restartsrfrreloadrrp)rmodulesrrr(rrr" pool_restarts rmaxminz [max [min]]cCs>|jjj}|r2|||\}}td|d|StddS)zModify autoscale settings.zautoscale now max=z min=zAutoscale not enabledN)rfrrr`rrp)rrrrZmax_Zmin_rrr" autoscales  rGot shutdown from remotecKst|t|dS)zShutdown worker(s).N)rdwarningr)rmsgr(rrr"shutdowns rrr exchange_typerz' [exchange [type [routing_key]]]cKs2|jj|jj|||pd|fi|td|S)z2Tell worker(s) to consume from task queue by name.directz add consumer )rf call_soonZadd_task_queuer)rrrrroptionsrrr" add_consumer s  rzcKs |j|jj|td|S)z9Tell worker(s) to stop consuming from task queue by name.zno longer consuming from )rfrZcancel_task_queuer)rr_rrr"cancel_consumersrcCs |jjrdd|jjjDSgS)z:List the task queues a worker is currently consuming from.cSsg|]}t|jddqS)T)Zrecurse)dictZas_dict)rNrrrr"r+sz!active_queues..)rfZ task_consumerZqueuesrrrr" active_queues's r)F)FN)NNN)N)N)NF)rrr)r)r )r )NFN)NN)r)NNN)Rr/rr collectionsrrZbilliard.commonrZkombu.utils.encodingrZcelery.exceptionsrZcelery.platformsrraZcelery.utils.functionalrZcelery.utils.logr Zcelery.utils.serializationr r Zcelery.utils.timer r,rr^rYr__all__rr.rdrrr$rr<r>r@rBrDrRrequests __getitem__rQr __contains__rrLrkrGrerfloatrurwryrrrrrrrrrWrVr_rintrrrrrrrrrrrrrrr"s               #  $