Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/__pycache__/control.cpython-39.pyc
Ðазад
a t�h�M � @ s d Z ddlZddlZddlmZmZmZ ddlmZ ddl m Z ddl m Z ddl mZ ddlmZ dd lmZ dd lmZmZ dd lmZ d d lmZ d dl m Z dZ dZ ee �Z!edg d��Z"dd� Z#dd� Z$G dd� de�Z%dd� Z&dd � Z'e'� d d � �Z(e'd d d!efgd"�d�d$d%��Z)d&d'� Z*e'd(d)d*�d+d,� �Z+ej,j-fd-d.�Z.ej/j0ej1j0fd/d0�Z2e&d1d)d*�d�d2d3��Z3e&d4d5d*�d�d6d7��Z4d�d8d9�Z5e&d1d:e6fgd;d<�d=d>� �Z7e&d?e6fd@e6fgdAdB�dCd@� �Z8e&d?e6fdDe9fdEe9fgdFdB�d�dGdH��Z:e'� dIdJ� �Z;e&� d�dKdL��Z<e&� dMdN� �Z=e&� dOdP� �Z>e&� dQdR� �Z?e'd#dS�d�dTdU��Z@e'dVdW�dXdY� �ZAe'� dZd[� �ZBe'd\d]�d^d_� �ZCd`da� ZDe'dbd]�dcdd� �ZEe'ded]�d�dfdg��ZFe'dhd]�didj� �ZGe'dkdldmdn�d�dodp��ZHe'dqdre6fdseIfdteIfgdudv�d�dzd{��ZJe'� d|d}� �ZKe'd~eIfgddB�d�d�d���ZLe&d�eIfgd�dB�d�d�d���ZMe&d�eIfgd�dB�d�d�d���ZNe&� d�d�d���ZOe&d�eIfd�eIfgd�dB�d�d�d���ZPe&� d�d�d���ZQe&d�e6fd�e6fd�e6fd�e6fgd�dB�d�d�d���ZRe&d�e6fgd�dB�d�d�� �ZSe'� d�d�� �ZTdS )�z.Worker remote control command implementations.� N)�UserDict� defaultdict� namedtuple)� TERM_SIGNAME)� safe_repr)�WorkerShutdown)�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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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# �_inner7 s � z Panel._register.<locals>._innerr ) r( r6 r r r r r r r r r7 r r5 r# r' 2 s zPanel._register) NNr+ Tr, NNNN) r/ � __module__� __qualname__r0 r3 r4 � 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_commandD s r= c K s t jf ddi| ��S )Nr �inspectr; r< r r r# �inspect_commandH s r? c C s t | j�� �S )z6Information about Celery installation for bug reports.)r �appZ bugreportr r r r# �reportN s rA Z dump_confz[include_defaults=False]� with_defaults)r r r Fc K s t | jjj|d�ttd�S )zList configuration.)rB )Z keyfilterZunknown_type_filter)r r@ �conf�table�_wanted_config_keyr )r rB r) r r r# rC T s �rC c C s t | t�o| �d� S )N�__)� isinstance�str� startswith)�keyr r r# rE ` s rE �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>l s �z query_task.<locals>.<dictcomp>)�_find_requests_by_idr )r rK r) r r r# � query_taskf s �rS c c s0 | D ]&}z||�V W q t y( Y q0 qd S r& )�KeyError)rK � get_request�task_idr r r# rR r s rR c C s || �r dS || �rdS dS )N�active�reserved�readyr )�requestZ is_active� is_reservedr r r# rM { s rM rV 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 �_revokerG �dictr )r rV � terminate�signalr) �task_idsr r r# �revoke� s rb �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 )r2 )rO �hr r r# rQ � � z-revoke_by_stamped_headers.<locals>.<dictcomp>zheaders z' flagged as revoked, but not terminated�stamps�r` z were not terminatedz revoked)�_signals�signumr rG �list�itemsr � worker_stateZrevoked_stamps�getr �active_requestsr r\ �hasattrrg �updater_ �consumer�pool)r rc r_ r` r) rj �headerrg Zupdated_stampsro Z#terminated_scheme_to_stamps_mappingrP Zexpected_header_keyZexpected_header_valueZ actual_headerZmatching_stamps_for_requestr r r# �revoke_by_stamped_headers� s. ru 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)rh zterminate: tasks unknownz terminate: {}z, z Tasks flagged as revoked: %s)�lenr\ rm �revokedrq ri rj r rR rL �add�loggerrN r_ rr rs r �format�join) r ra r_ r` r) �sizeZ terminatedrj rZ Zidstrr r r# r] � s$ r] r` 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)r_ r` )rb )r r` rV r) r r r# r_ � s r_ � 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% r@ �tasksr rT ry r$ rr Zreset_rate_limitsrN 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) r@ r� rT ry r$ r% Zsoft_time_limit� time_limitrN 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)r@ 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)rr Zgossip�election)r rL Ztopic�actionr) r r r# r� C 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)rr �event_dispatcher�groupsrx ry rN r �r � dispatcherr r r# � enable_eventsP 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)rr r� r� �discardry rN 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� )ry �debugrr r� �sendrm Z SOFTWARE_INFOr� r r r# � heartbeatf 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)rw r� N) �hostnamery rN rm rw rq �purge�_datar@ r� �forward)r Z from_noderw r) r r r# �hellop s �r� g�������?)r c K s t d�S )zPing worker(s).�pong)r r� r r r# �ping� s r� c K s | j j�� S )z&Request worker statistics/information.)rr � 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.)rk �_iter_schedule_requestsrr �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�priorityrZ ) Zschedule�queue�entryr � IndexError� TypeErrorrG r r� � isoformatr� rN )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 �rN �rO rZ r r r# � <listcomp>� rf z reserved.<locals>.<listcomp>)�tsetrm �reserved_requestsro )r r) Zreserved_tasksr r r# rX � s ��rX 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� rm ro )r r� r) r r� r# rW � s �rW Z dump_revokedc K s t tj�S )zList of revoked task-ids.)rk rm rw r� r r r# rw � s rw 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)rI �rO 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& )�getattrrH )rO �field�r� r r# rQ � s �z5registered.<locals>._extract_info.<locals>.<dictcomp>c S s g | ]}d � |��qS )rd )r{ )rO �fr r r# r� � rf z5registered.<locals>._extract_info.<locals>.<listcomp>z{} [{}]� )rl rz r6 r{ )r� �fieldsrN )r� r� r# � _extract_info� s �z!registered.<locals>._extract_infoc s g | ]}� �| ��qS r r r� )r� �regr r# r� � rf z registered.<locals>.<listcomp>)r@ 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��objectsr r# �<lambda>� rf zobjgraph.<locals>.<lambda>)r� � highlight�filenamer� ) �objgraph� ImportErrorry rN �tempfile�NamedTemporaryFileZby_typeZ show_backrefsr6 )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)rr r� � autoscalerr% rs 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)rr r� r� r% rs �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)r@ rC Zworker_pool_restartsrr 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)rr r� r� rq r r� )r r� r� r� Zmax_Zmin_r r r# � autoscale6 s r� �Got shutdown from remotec K s t �|� td��dS )zShutdown worker(s).r N)ry �warningr )r �msgr) r r r# �shutdownC 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 )rr � call_soonZadd_task_queuer )r r� r r� r �optionsr r r# � add_consumerL 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 )rr 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)�recurse)r^ �as_dict)rO r� r r r# r� n s �z!active_queues.<locals>.<listcomp>)rr Z task_consumerZqueuesr r r r# � active_queuesj s �r� )F)FN)FN)FN)NNN)N)N)F)NF)r� r� r )r� )r )r )NFN)NN)r� )NNN)Ur0 r� r� � collectionsr r r Zbilliard.commonr Zkombu.utils.encodingr Zcelery.exceptionsr Zcelery.platformsr ri Zcelery.utils.functionalr Zcelery.utils.logr Zcelery.utils.serializationr r Zcelery.utils.timer r- r rm rZ r �__all__r� r/ ry r r r% r r= r? rA rC rE rS �requests� __getitem__rR ro � __contains__r� rM rb ru r] rH r_ r �floatr� r� r� r� r� r� r� r� r� r� r� rX rW rw r� �intr� r� r� r� r� r� r� r� r� r� r� r r r r# �<module> s* � � � � � � 6 � � $� � � � � � � �� � �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка