Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/bin/__pycache__/control.cpython-39.pyc
Ðазад
a t�h�! � @ s$ d Z ddlmZ ddlmZ ddlZddlmZ ddlm Z m Z m Z m Z ddl mZ ddlmZ dd lmZ dd lmZ d5d d �Zdd� Zdd� Zed Zeedd�dd�Zed�dd�Zee d�dd�Z ej e d �ej d d e e d d d!d"�ej d#d$e e d d%d&�ej d'd(e d)d d*d+�ej!e d,d-� ������Z"ej e d.d)id/�e�#d0�ed1�ej d d e e d d d!d"�ej d#d$e e d d%d&�ej d'd(e d)d d*d+�ej!e d2d1� ��������Z$ej e d.d)id/�e�#d0�ed3�ej d d e e d d d!d"�ej d#d$e e d d%d&�ej d'd(e d)d d*d+�ej!e d4d3� ��������Z%dS )6z@The ``celery control``, ``. inspect`` and ``. status`` programs.� )�partial)�LiteralN)�dumps)�COMMA_SEPARATED_LIST� CeleryCommand� CeleryOption�handle_preload_options)�CeleryCommandException)�EX_UNAVAILABLE)�text)�PanelFc C sl t t|��}|| }| jj|� d�ddd�}| j�|�\}}| jjd|� |� �|r^t�|d�nd|d� d S ) Nz: �cyanT)Zfg�boldz->� � )Z show_body)�next�iter�obj�style�prettyZsay_chatr �indent)�ctx�replies� show_reply�node�reply�statusZpreply� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/bin/control.py�_say_remote_command_reply s �r c c s� d}z�t |�D ]h\}}z| j| \}}W n2 tyZ | jrBY qxt�d�|| j���Y q0 ||d urn||�n|fV qW ||d � |d d �< n||d � |d d �< 0 d S )Nr z Command {!r} takes arguments: {})� enumerate�args� IndexError�variadic�click� UsageError�format� signature)�meta�methodr! �i�arg�name�typr r r �_consume_arguments s �� r. c C sJ t j| }i }|jr0|�dd� t|| |�D �� |jrF|�|j|i� |S )Nc S s i | ]\}}||�qS r r )�.0�k�vr r r � <dictcomp>/ s z&_compile_arguments.<locals>.<dictcomp>)r r( r! �updater. r# )�commandr! r( � argumentsr r r �_compile_arguments+ s �r6 )�inspect�control)�type_r4 �returnc C s< t | �}||vr8d�|�}tjd|� d| � d|� �d��d S )Nz, zCommand z not recognized. Available z commands: )�message)�_get_commands_of_type�joinr$ r% )r9 r4 �choicesZcommand_listingr r r �_verify_command_name: s �r? �r9 c s4 t jd d�� fdd� }t jddd� � d�dd|d �S ) N)r r: c s� |sd S t � �}t�� }|�� �� � d���\ g }|�� D ]4\}}|jrZ|� d|j� �}n|}|�||jf� q:|� |� W d � n1 s�0 Y | j j |� � dd� | � � d S )Nz Commands� F)�nl)r< r$ � HelpFormatter�section� capitalize�itemsr' �append�helpZwrite_dlr �echo�getvalue�exit) r �param�valuer> � formatterZ command_list� command_name�infoZcommand_previewr@ r r �callbackE s (z _list_option.<locals>.callbackz--listTzList available z commands and exit.F)�is_flagrH Z expose_valueZis_eagerrQ )r$ �Context�option)r9 rQ r r@ r � _list_optionD s �rU )r9 r: c s$ � fdd�t j�� D �}tt|��S )Nc s( g | ] \}}|j � kr|jr||f�qS r )�type�visible)r/ r, rP r@ r r � <listcomp>c s �z)_get_commands_of_type.<locals>.<listcomp>)r r( rF �dict�sorted)r9 Zcommand_name_info_pairsr r@ r r< b s �r< )�clsz-tz --timeoutg �?zRemote Control Optionsz%Timeout in seconds waiting for reply.)r[ rV �default� help_grouprH z-dz --destinationz/Comma separated list of destination node names.)r[ rV r] rH z-jz--jsonTzUse json as output format.)r[ rR r] rH c K s� |rdnt t| �}| jjjj|||d��� }|s<tdtd��|rP| j� t |�� t |�}|� dd�s�| j� d� |t�|d��� dS ) z%Show list of workers that are online.N��timeout� destinationrQ �'No nodes replied within time constraint�r; � exit_code�quietF� {} {} online.r )r r r �appr8 r7 Zpingr r rI r �len�getr& r � pluralize)r r_ r` �json�kwargsrQ r � nodecountr r r r j s" � � �r Zallow_extra_args)r[ Zcontext_settingsr4 r7 c K s� t d|� |rdn tt| dd�}t|| j�}| jjjj|||d�}|j |fi |��} | sdt dt d��|r|| j� t | �� dS t| �} | jjs�| j� d�| t�| d ��� dS ) z~Inspect the workers by sending them the COMMAND inspect command. Availability: RabbitMQ (AMQP) and Redis transports. r7 NT�r r^ ra rb re r )r? r r r6 r! r rf r8 r7 �_requestr r rI r rg rd r& r ri ) r r4 r_ r` rj rk rQ r5 r7 r rl r r r r7 � s. � �� �r8 c C st t d|� |rdn tt| dd�}| j}t||�}| jjjj||||d|d�}|s\t dt d��|rp| j� t |�� dS )zxSend the COMMAND control command to the workers. Availability: RabbitMQ (AMQP), Redis, and MongoDB transports. r8 NTrm )r_ r` rQ r r5 ra rb ) r? r r r! r6 r rf r8 � broadcastr r rI r ) r r4 r_ r` rj rQ r! r5 r r r r r8 � s& � ��)F)&�__doc__� functoolsr �typingr r$ Zkombu.utils.jsonr Zcelery.bin.baser r r r Zcelery.exceptionsr Zcelery.platformsr Z celery.utilsr Zcelery.worker.controlr r r. r6 Z_RemoteControlType�strr? rU rY r< r4 rT �floatZ pass_contextr �argumentr7 r8 r r r r �<module> s� ������� ����
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка