Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/bin/__pycache__/graph.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlZddlmZ ddlZddlmZmZ ddlm Z m Z e� � ej edd� ���Z e jedd id �ej d d � ��Ze jedd id �ej d d� ��ZdS )� The ``celery graph`` command.� N)� itemgetter)� CeleryCommand�handle_preload_options)�DependencyGraph�GraphFormatterc C s dS )r N� )�ctxr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/bin/graph.py�graph s r Zallow_extra_argsT)�clsZcontext_settingsc C sh | j j�� }dd� | jp ddgD �}d|v rN|jj}d|v rX|j�|jj� n |jjj}|�t j � dS )zDisplay bootsteps graph.c S s h | ] }|� � �qS r )�lower��.0�argr r r � <setcomp> � z bootsteps.<locals>.<setcomp>�worker�consumerN) �obj�appZWorkController�args� blueprintr Z connect_withr �to_dot�sys�stdout)r r �includeZ worker_graphr r r � bootsteps s r c s �fdd��d-dd��t �fdd�| jD ���d�v �d d � �G d d � d �}G �fd d�d|�� G � fdd�dt�}dd� �G dd� d|�}G ��fdd�d|�}G ��fdd�d|�}ddlm} |d��t��d d �p�d�}t��d d �p�d�}|f��fd d!� } | jj} z �d" } ��d#��p&g } W nb t �y� | j � � � � �pLi } g g } } | � � D ]&\}}| �|� | �|d$ d% � �q`Y n0 t| �}��d&| jj�}i }| | d�} |�r�||k�r�| dd � | d' g } t| �D ]*\}} | ttt| ���d(|�|| | < �q�|��d)| �� �� ��}|�r4||�nd*}t|� d+�}|�|� |�r^|�|� dg}t| �D ]�\}}|||d,�}|�|� |�||� |�r�|�||� |�|j�} | �r�| D ]$}� |�}|�|� |�||� �q�|d d7 < �ql|�t j � d*S ).zDisplay workers graph.c s � t dd�| �d���S )Nr � �:)r � partition)r )� maybe_listr r � simplearg% s zworkers.<locals>.simplearg�,c S s* | d || d v r | d � |�n| d fS )Nr � )�split)�l�sepr r r r! ( s zworkers.<locals>.maybe_listc 3 s | ]}� |�V qd S �Nr r )r" r r � <genexpr>+ r zworkers.<locals>.<genexpr>�genericc S s d� t| �j| j�d�d �S )Nz {} ({}://)z://r )�format�type�__name__�_labelr% )�noder r r � generic_label. s �z workers.<locals>.generic_labelc @ s. e Zd ZdZi Zddd�Zdd� Zdd� ZdS ) zworkers.<locals>.NodeNc S s || _ || _d S r( )r. �pos)�self�labelr1 r r r �__init__6 s z workers.<locals>.Node.__init__c S s | j S r( �r. �r2 r r r r3 : s zworkers.<locals>.Node.labelc S s | � � S r( �r3 r6 r r r �__str__= s z workers.<locals>.Node.__str__)N)r- � __module__� __qualname__Z force_label�schemer4 r3 r8 r r r r �Node2 s r< c s0 e Zd Zddddddd�Z� �fdd �Z� ZS ) zworkers.<locals>.ThreadZ lightcyan4�yellowZoval� g333333�?�black)� fillcolorZ fontcolor�shapeZfontsize�width�colorc s$ || _ t� jdt��� �dd� d S )Nzthr-r )r3 r1 )� real_label�superr4 �next)r2 r3 �kwargs)� __class__�tidsr r r4 J s �z workers.<locals>.Thread.__init__)r- r9 r: r; r4 � __classcell__r )rI )rH r �Thread@ s � rK c s4 e Zd Zdd� Z� fdd�Zdd� Z� fdd�Zd S ) zworkers.<locals>.Formatterc S s |o |� � S r( r7 �r2 r r r r r3 S s z workers.<locals>.Formatter.labelc sD |j rt|j�n|j}t|� �r*|j|d< | �|t| jfi |���S )Nr3 )r1 �dictr; � isinstancerD � draw_nodeZ node_scheme)r2 r r; �rK r r r/ V s �z workers.<locals>.Formatter.nodec S s | � |t| jfi |j���S r( )rO rM Z term_schemer; rL r r r � terminal_node^ s �z(workers.<locals>.Formatter.terminal_nodec s* t |� �r|jddd� | �||| j|�S )N�none�tee)Z arrowheadZ arrowtail)rN �updateZ draw_edgeZ edge_scheme)r2 �a�b�attrsrP r r �edgec s z workers.<locals>.Formatter.edgeN)r- r9 r: r3 r/ rQ rX r rP r r � FormatterQ s rY c s6 ddddddddd d d � � d � � fd d�t| �D ��S )Nu ₀u ₁u ₂u ₃u ₄u ₅u ₆u ₇u ₈u ₉) �0�1�2�3�4�5�6�7�8�9� c s g | ] }� | �qS r r )r �i��Sr r � <listcomp>k r z.workers.<locals>.subscript.<locals>.<listcomp>)�join�str)�nr rf r � subscripth s �zworkers.<locals>.subscriptc @ s e Zd ZdS )zworkers.<locals>.WorkerN)r- r9 r: r r r r �Workerm s rm c s* e Zd Zdddddd�Z� �fdd�Zd S ) zworkers.<locals>.Backend�folderr r$ r? Z peachpuff3)rA rB �heightrC r@ c s � r �| �S | j S r( r5 r6 �r* r0 r r r3 y s z workers.<locals>.Backend.labelN�r- r9 r: r; r3 r rp r r �Backendp s �rr c s( e Zd Zddddd�Z� �fdd�ZdS ) zworkers.<locals>.Broker�circleZ cadetblue3Z cadetblue4r$ )rA r@ rC ro c s � r �| �S | j S r( r5 r6 rp r r r3 � s z workers.<locals>.Broker.labelNrq r rp r r �Broker| s �rt r )�countr$ Zwmax� Ztmax� c s~ t | �}|o||k}d�v r4� �fdd�t| �D �} |rz| d|d � | |d g } d�� d �||d ��| |d < | S )N� enumeratec s$ g | ] \}}� � �|d �� ��qS )r$ r )r re r )�namerl r r rh � s �z/workers.<locals>.maybe_abbr.<locals>.<listcomp>r r$ u {}⎨…{}⎬r )�lenrx r+ )r& ry �max�sizeZabbr)r rl )ry r � maybe_abbr� s � � zworkers.<locals>.maybe_abbr�nodes�threads�poolzmax-concurrency�backend����P�brokerN)� formatter)r1 )r# ) rM r r � itertoolsru �int�getr r �KeyError�control�inspect�stats�items�appendrz ZconfZresult_backendrx �list�rangeZconnection_for_read�as_urir Zadd_arcZadd_edger. r r r )r r< rY rm rr rt ru ZWmaxZTmaxr} r �workersr Zrepliesr ZreplyZwlenr� Z threads_forre r� �depsZ curworker�threadr )rK r r* r0 r! r" rl rI r r� ! sx � � r� )�__doc__r �operatorr ZclickZcelery.bin.baser r Zcelery.utils.graphr r �groupZ pass_contextr �commandr r� r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка