Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/worker/__pycache__/ |
a
��Sh�M � @ s d Z ddlZddlZddlmZmZmZ ddlmZ ddl m
Z
ddl m Z ddl
mZ ddl
mZ dd lmZ dd
lmZ dd lmZmZ dd lmZ d
dlmZ d
dl m Z dZ dZ ee!�Z"edg d��Z#dd� Z$dd� Z%G dd� de�Z&dd� Z'd d � Z(e(� d d � �Z)e(d d!d"efgd#�d�d%d&��Z*d'd(� Z+e(d)d*d+�d,d-� �Z,e j-j.fd.d/�Z/e j0j1e j2j1fd0d1�Z3e'd2d*d+�d�d3d4��Z4e'd5d6d+�d�d7d8��Z5d�d9d:�Z6e'd2d;e7fgd<d=�d>d?� �Z8e'd@e7fdAe7fgdBdC�dDdA� �Z9e'd@e7fdEe:fdFe:fgdGdC�d�dHdI��Z;e(� dJdK� �Z<e'� d�dLdM��Z=e'� dNdO� �Z>e'� dPdQ� �Z?e'� dRdS� �Z@e(d$dT�d�dUdV��ZAe(dWdX�dYdZ� �ZBe(� d[d\� �ZCe(d]d^�d_d`� �ZDdadb� ZEe(dcd^�ddde� �ZFe(dfd^�d�dgdh��ZGe(did^�djdk� �ZHe(dldmdndo�d�dpdq��ZIe(drdse7fdteJfdueJfgdvdw�d�d{d|��ZKe(� d}d~� �ZLe(deJfgd�dC�d�d�d���ZMe'd�eJfgd�dC�d�d�d���ZNe'd�eJfgd�dC�d�d�d���ZOe'� d�d�d���ZPe'd�eJfd�eJfgd�dC�d�d�d���ZQe'� d�d�d���ZRe'd�e7fd�e7fd�e7fd�e7fgd�dC�d�d�d���ZSe'd�e7fgd�dC�d�d�� �ZTe(� d�d�� �ZUdS )�z.Worker remote control command implementations.� N)�UserDict� defaultdict�
namedtuple)� TERM_SIGNAME)� safe_repr)�WorkerShutdown)�EX_OK)�signals)�
maybe_list)�
get_logger)�jsonify� strtobool)�rate� ��state)�Request)�Panel)�exchange� routing_key�
rate_limit�controller_info_t)�alias�type�visible�default_timeout�help� signature�args�variadicc C s d| iS )N�ok� ��valuer! r! �?/usr/local/lib/python3.9/site-packages/celery/worker/control.pyr s r c C s d| iS )N�errorr! r" r! r! r$ �nok# s r& c
@ s2 e Zd ZdZi Zi Zedd� �Zed
dd ��ZdS ) r z+Global registry of remote control commands.c O s( |r| j f i |��|� S | j f i |��S �N)� _register)�clsr �kwargsr! r! r$ �register- s zPanel.registerN�controlT� �?c
s" � ��������� f
dd�}
|
S )Nc s^ �p| j }�p$| jpd�� �d�d }| �j|< t� �� �|�����j|< � rZ| �j� < | S )N� �
r )�__name__�__doc__�strip�split�datar �meta)ZfunZ control_nameZ_help�
r r r) r r �namer r r r r! r$ �_inner8 s
�
z Panel._register.<locals>._innerr! ) r) r7 r r r r r r r r r8 r! r6 r$ r( 3 s
zPanel._register) NNr, Tr- NNNN) r0 �
__module__� __qualname__r1 r4 r5 � classmethodr+ r( r! r! r! r$ r ' s
�r c K s t jf ddi| ��S )Nr r, �r r+ �r* r! r! r$ �control_commandE s r> c K s t jf ddi| ��S )Nr �inspectr< r= r! r! r$ �inspect_commandI s r@ c C s t | j�� �S )z6Information about Celery installation for bug reports.)r �appZ bugreportr r! r! r$ �reportO s rB Z dump_confz[include_defaults=False]�
with_defaults)r r r Fc K s t | jjj|d�ttd�S )zList configuration.)rC )Z keyfilterZunknown_type_filter)r rA �conf�table�_wanted_config_keyr )r rC r* r! r! r$ rD U s �rD c C s t | t�o| �d� S )N�__)�
isinstance�str�
startswith)�keyr! r! r$ rF a s rF �idsz[id1 [id2 [... [idN]]]])r r c K s dd� t t|��D �S )z!Query for task information by id.c S s i | ]}|j t|�|�� f�qS r! )�id�_state_of_task�info)�.0�reqr! r! r$ �
<dictcomp>m s �z query_task.<locals>.<dictcomp>)�_find_requests_by_idr
)r rL r* r! r! r$ �
query_taskg s
�rT c c s0 | D ]&}z||�V W q t y( Y q0 qd S r' )�KeyError)rL � get_request�task_idr! r! r$ rS s s
rS c C s || �r dS || �rdS dS )N�active�reserved�readyr! )�request� is_active� is_reservedr! r! r$ rN | s
rN rW c K sR t t|�p g �d }}t| |||fi |��}t|t�rBd|v rB|S td|� d��S )z�Revoke 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
�_revokerH �dictr )r rW � terminate�signalr* �task_idsr! r! r$ �revoke� s
rd �headersz/[key1=value1 [key2=value2 [... [keyN=valueN]]]]c K s. t �|p
t�}t|t�r&dd� |D �}|�� D ]2\}}ttj� |�pFg �tt|�� }|tj|< q.|svt
d|� d��S ttj �} t t
�}
| D ]z} t| d�r�| jr�|�� D ]\\} }
| | jv r�t|
�}
t| j| �}t
|�t
|
�@ }|r�|
| �|� | j| jj|d� q�q�|
�s t
d|� d��S t
d|
� d��S ) a� Revoke 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]}
c S s& i | ] }|� d �d |� d �d �qS )�=r r )r3 )rP �hr! r! r$ rR � � z-revoke_by_stamped_headers.<locals>.<dictcomp>zheaders z' flagged as revoked, but not terminated�stamps�rb z were not terminatedz revoked)�_signals�signumr rH �list�itemsr
� worker_stateZrevoked_stamps�getr �active_requestsr r^ �hasattrri �updatera �consumer�pool)r re ra rb r* rl �headerri Zupdated_stampsrq Z#terminated_scheme_to_stamps_mappingrQ Zexpected_header_keyZexpected_header_valueZ
actual_headerZmatching_stamps_for_requestr! r! r$ �revoke_by_stamped_headers� s.
rw c
K s� t |�}t� }tj�|� |r�t�|p(t�}t|�D ]L}|j |vr4|�
|j � t � d|j |� |j
| jj|d� t |�|kr4 q�q4|s�td�S td�d�|���S d�|�} t � d| � |S )NzTerminating %s (%s)rj zterminate: tasks unknownz
terminate: {}z, z Tasks flagged as revoked: %s)�lenr^ ro �revokedrs rk rl r rS rM �add�loggerrO ra rt ru r �format�join)
r rc ra rb r* �sizeZ
terminatedrl r[ Zidstrr! r! r$ r_ � s$
r_ rb z <signal> [id1 [id2 [... [idN]]]])r r r c K s t | |d|d�S )z+Terminate task by task id (or list of ids).T)ra rb )rd )r rb rW r* r! r! r$ ra � s ra � task_namer z0<task_name> <rate_limit (e.g., 5/s | 5/m | 5/h)>)r r c
K s� z t |� W n2 ty> } ztd|���W Y d}~S d}~0 0 z|| jj| _W n* ty| tjd|dd� td� Y S 0 | j �
� |s�t� d|� t d�S t� d ||� t d
�S ) z�Tell 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 %sT��exc_info� unknown taskz)Rate limits disabled for tasks of type %sz rate limit disabled successfullyz(New rate limit for tasks of type %s: %s.z new rate limit set successfully)
r �
ValueErrorr& rA �tasksr rU r{ r% rt Zreset_rate_limitsrO r )r r r r* �excr! r! r$ r � s& $ �
��soft�hardz#<task_name> <soft_secs> [hard_secs]c K s` z| j j| }W n* ty: tjd|dd� td� Y S 0 ||_||_t�d|||� t d�S )z�Tell 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 %sTr� r� z5New time limits for tasks of type %s: soft=%s hard=%sz time limits set successfully)
rA r� rU r{ r% r& Zsoft_time_limit�
time_limitrO r )r r r� r� r* �taskr! r! r$ r� s ��r� c K s d| j jjiS )z Get current logical clock value.�clock)rA r� r# �r r* r! r! r$ r� > s r� c K s | j jr| j j�|||� dS )z�Hold election.
Arguments:
id (str): Unique election id.
topic (str): Election topic.
action (str): Action to take for elected actor.
N)rt Zgossip�election)r rM Ztopic�actionr* r! r! r$ r� D s r� c C s> | j j}|jr6d|jvr6|j�d� t�d� td�S td�S )z+Tell worker(s) to send task-related events.r� z)Events of group {task} enabled by remote.ztask events enabledztask events already enabled)rt �event_dispatcher�groupsrz r{ rO r �r �
dispatcherr! r! r$ �
enable_eventsQ s
r� c C s8 | j j}d|jv r0|j�d� t�d� td�S td�S )z3Tell worker(s) to stop sending task-related events.r� z*Events of group {task} disabled by remote.ztask events disabledz task events already disabled)rt r� r� �discardr{ rO r r� r! r! r$ �disable_events\ s
r� c C s, t �d� | jj}|jddditj�� dS )z3Tell worker(s) to send event heartbeat immediately.z Heartbeat requested by remote.�worker-heartbeat�freq� N)r� )r{ �debugrt r� �sendro Z
SOFTWARE_INFOr� r! r! r$ � heartbeatg s
r� )r c K sJ || j krFt�d|� |r&tj�|� tj�� tjj| jj �
� d�S dS )zRequest mingle sync-data.z sync with %s)ry r� N) �hostnamer{ rO ro ry rs �purge�_datarA r� Zforward)r Z from_nodery r* r! r! r$ �helloq s
�r� g�������?)r c K s t d�S )zPing worker(s).Zpong)r r� r! r! r$ �ping� s r� c K s | j j�� S )z&Request worker statistics/information.)rt �
controller�statsr� r! r! r$ r� � s r� Z
dump_schedule)r c K s t t| jj��S )z0List of currently scheduled ETA/countdown tasks.)rm �_iter_schedule_requestsrt �timerr� r! r! r$ � scheduled� s r� c
c sl | j jD ]^}z|jjd }W n ttfy6 Y qY q0 t|t�r|jrR|j� � nd |j
|� � d�V qd S )Nr )�eta�priorityr[ ) Zschedule�queue�entryr �
IndexError� TypeErrorrH r r� � isoformatr� rO )r� ZwaitingZarg0r! r! r$ r� � s
�r� Z
dump_reservedc K s. | � tj�| � tj� }|s g S dd� |D �S )zAList of currently reserved tasks, not including scheduled/active.c S s g | ] }|� � �qS r! �rO �rP r[ r! r! r$ �
<listcomp>� rh z reserved.<locals>.<listcomp>)�tsetro �reserved_requestsrq )r r* Zreserved_tasksr! r! r$ rY � s
��rY Z dump_activec s � fdd�| � tj�D �S )z'List of tasks currently being executed.c s g | ]}|j � d ��qS )��safer� r� r� r! r$ r� � s �zactive.<locals>.<listcomp>)r� ro rq )r r� r* r! r� r$ rX � s
�rX Z dump_revokedc K s
t tj�S )zList of revoked task-ids.)rm ro ry r� r! r! r$ ry � s ry Z
dump_tasks�
taskinfoitemsz [attr1 [attr2 [... [attrN]]]])r r r c sJ | j j��pt�|r�n dd� �D �}�fdd�� � �fdd�t|�D �S )z�List 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.
c s s | ]}|� d �s|V qdS )zcelery.N)rJ �rP r� r! r! r$ � <genexpr>� s z registered.<locals>.<genexpr>c sB � fdd��D �}|r<dd� |� � D �}d�� jd�|��S � jS )Nc s. i | ]&}t � |d �d ur|tt � |d ���qS r' )�getattrrI )rP �field�r� r! r$ rR � s �z5registered.<locals>._extract_info.<locals>.<dictcomp>c S s g | ]}d � |��qS )rf )r} )rP �fr! r! r$ r� � rh z5registered.<locals>._extract_info.<locals>.<listcomp>z{} [{}]� )rn r| r7 r} )r� �fieldsrO )r� r� r$ �
_extract_info� s
�z!registered.<locals>._extract_infoc s g | ]}� �| ��qS r! r! r� )r� �regr! r$ r� � rh z registered.<locals>.<listcomp>)rA r� �DEFAULT_TASK_INFO_ITEMS�sorted)r r� �builtinsr* r� r! )r� r� r� r$ �
registered� s
�
r� g N@r �num� max_depthz.[object_type=Request] [num=200 [max_depth=10]])r r r �� �
r c s� z ddl }W n ty& td��Y n0 t�d|� tjdddd��H}|�|�d|� � |j� |� fd d
�|jd � d |jiW d � S 1 s�0 Y dS )
a Create 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"``.
r Nz Requires the objgraph libraryzDumping graph for type %rZcobjgz.pngF)�prefix�suffix�deletec s | � v S r' r! )�v�Zobjectsr! r$ �<lambda>� rh zobjgraph.<locals>.<lambda>)r� Z highlight�filenamer� ) �objgraph� ImportErrorr{ rO �tempfile�NamedTemporaryFileZby_typeZ
show_backrefsr7 )r r� r� r Z _objgraph�fhr! r� r$ r� � s
� �r� c K s ddl m} |� S )z Sample current RSS memory usage.r )�
sample_mem)Zcelery.utils.debugr� )r r* r� r! r! r$ � memsample� s r� �samplesz[n_samples=10]c K s( ddl m} t�� }|j|d� |�� S )z/Dump statistics of previous memsample requests.r )r� )�file)Z celery.utilsr� �io�StringIO�memdump�getvalue)r r� r* r� �outr! r! r$ r� s r� �nz[N=1]c K s4 | j jjrtd�S | j j�|� | j �|� td�S )z!Grow pool by n processes/threads.zJpool_grow is not supported with autoscale. Adjust autoscale range instead.zpool will grow)rt r� �
autoscalerr& ru Zgrow�_update_prefetch_countr �r r� r* r! r! r$ � pool_grow s
r� c K s6 | j jjrtd�S | j j�|� | j �| � td�S )z#Shrink pool by n processes/threads.zLpool_shrink is not supported with autoscale. Adjust autoscale range instead.zpool will shrink)rt r� r� r& ru �shrinkr� r r� r! r! r$ � pool_shrink s
r� c K s2 | j jjr&| jjj|||d� td�S td��dS )zRestart execution pool.)�reloaderzreload startedzPool restarts not enabledN)rA rD Zworker_pool_restartsrt r� �reloadr r� )r �modulesr� r� r* r! r! r$ � pool_restart- s
r� �max�minz [max [min]]c C s> | j jj}|r2|�||�\}}td|� d|� ��S td��dS )zModify autoscale settings.zautoscale now max=z min=zAutoscale not enabledN)rt r� r� rs r r� )r r� r� r� Zmax_Zmin_r! r! r$ � autoscale7 s
r� �Got shutdown from remotec K s t �|� tt��dS )zShutdown worker(s).N)r{ �warningr r )r �msgr* r! r! r$ �shutdownD s
r� r� r �
exchange_typer z'<queue> [exchange [type [routing_key]]]c K s2 | j j| j j|||pd|fi |�� td|� ��S )z2Tell worker(s) to consume from task queue by name.�directz
add consumer )rt � call_soonZadd_task_queuer )r r� r r� r �optionsr! r! r$ � add_consumerM s ��r� z<queue>c K s | j �| j j|� td|� ��S )z9Tell worker(s) to stop consuming from task queue by name.zno longer consuming from )rt r� Zcancel_task_queuer )r r� �_r! r! r$ �cancel_consumer_ s �r� c C s | j jr dd� | j jjD �S g S )z:List the task queues a worker is currently consuming from.c S s g | ]}t |jd d���qS )T)Zrecurse)r` Zas_dict)rP r� r! r! r$ r� o s �z!active_queues.<locals>.<listcomp>)rt Z
task_consumer�queuesr r! r! r$ �
active_queuesk s
�r� )F)FN)FN)FN)NNN)N)N)F)NF)r� r� r )r� )r )r )NFN)NN)r� )NNN)Vr1 r� r� � collectionsr r r Zbilliard.commonr Zkombu.utils.encodingr Zcelery.exceptionsr Zcelery.platformsr r rk Zcelery.utils.functionalr
Zcelery.utils.logr Zcelery.utils.serializationr r
Zcelery.utils.timer r. r ro r[ r �__all__r� r0 r{ r r r& r r> r@ rB rD rF rT �requests� __getitem__rS rq � __contains__r� rN rd rw r_ rI ra r �floatr� r� r� r� r� r� r� r� r� r� r� rY rX ry r� �intr� r� r� r� r� r� r� r� r� r� r� r! r! r! r$ �<module> s,
� �
�
�
� � 6
�
�
$�
� �
�
�
�
� �� � �