Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/events/__pycache__/dumper.cpython-39.pyc
Ðазад
a t�h, � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dZ edd �Z d d d d �Z dZ dd� Z G dd� d�Zdejfdd�Zedkr�e� dS )z�Utility to dump events to screen. This is a simple program that dumps events to the console as they happen. Think of it like a `tcpdump` for Celery events. � N)�datetime)�app_or_default)�LRUCache)�humanize_seconds)�Dumper�evdumpi� )�limit�shutdown�started� heartbeat)zworker-offlinez worker-onlinezworker-heartbeatz--> Cannot connect to %s: %s. Trying again %s c C s6 zt | �� W S ty0 | �� �dd� Y S 0 d S )N�-� )� HUMAN_TYPES�lower�KeyError�replace)�type� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/events/dumper.py� humanize_type s r c @ s6 e Zd ZdZejfdd�Zdd� Zdd� Zdd � Z d S ) r zMonitor events.c C s || _ d S )N��out)�selfr r r r �__init__' s zDumper.__init__c C s4 t || jd� z| j�� W n ty. Y n0 d S )N)�file)�printr �flush�AttributeError)r �msgr r r �say* s z Dumper.sayc s� t �� �d��}� �d��� }� �d�}|�d�r�� �d�}|dv rpd�� �d�|� �d �� �d �� }t|< n t�|d �}| �||||� �S d � � fd d�t � �D ��}|r�dp�d }| � |� d|� dt |�� |� d|� �� d S )N� timestampr �hostnameztask-�uuid)z task-receivedz task-sentz{}({}) args={} kwargs={}�name�args�kwargs� �, c 3 s | ]}|� d � | � �V qdS ��=Nr ��.0�key��evr r � <genexpr>A s z"Dumper.on_event.<locals>.<genexpr>�:� [�] r ) r �utcfromtimestamp�popr � startswith�format� TASK_NAMES�get�format_task_event�join�sortedr r ) r r. r r r! r" �task�fields�sepr r- r �on_event2 s( � �� zDumper.on_eventc sZ d� � fdd�t� �D ��}|r$dp&d}| �|� d|� dt|�� |� d|� d|� � � d S ) Nr' c 3 s | ]}|� d � | � �V qdS r( r r* ��eventr r r/ H s z+Dumper.format_task_event.<locals>.<genexpr>r0 r& r1 r2 r )r: r; r r )r r! r r r< rA r= r> r r@ r r9 G s � zDumper.format_task_eventN) �__name__� __module__� __qualname__�__doc__�sys�stdoutr r r? r9 r r r r r $ s r c s� t | �} t|d����d� | �� �� � � �fdd�}z,� �|� | jj� d�jid�}|� � W q6 t t fy� � o~� � � Y S � j � j y� ��d� Y q60 q6dS ) zStart event dump.r z -> evdump: starting capture...c s$ �� t� �� | t|dd�f � d S )N�inr )r �CONNECTION_ERROR�as_urir )�exc�interval��connZdumperr r �_error_handlerV s �z evdump.<locals>._error_handler�*)�handlersz(-> Connection lost, attempting reconnectN)r r r Zconnection_for_read�cloneZensure_connection�eventsZReceiverr? �capture�KeyboardInterrupt� SystemExit�closeZconnection_errorsZchannel_errors)Zappr rO �recvr rM r r O s r �__main__)rE rF r Z celery.appr Zcelery.utils.functionalr Zcelery.utils.timer �__all__r7 r rI r r rG r rB r r r r �<module> s" �+
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка