Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/utils/__pycache__/log.cpython-39.pyc
Ðазад
a t�h5" � @ sJ d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z m Z ddl m Z ddl mZ ddlmZ dd lmZ d Zd Zd aej�d d �Zd dhZed � ZZ dd� Z dd� Z edd� �Z d-dd�Z dd� Z!dd� Zed�Z"ed �Z#d d � Z$d d � Z%G d!d"� d"ej&�Z'G d#d$� d$�Z(d%d&� Z)d'd(� Z*d)d*� Z+d.d+d,�Z,dS )/zLogging utilities.� N)�contextmanager)�AnyStr�Sequence)� LOG_LEVELS)� get_logger)�safe_str� )�colored) �ColorFormatter� LoggingProxy� base_logger�set_in_sighandler� in_sighandlerr �get_task_logger�mlevel�get_multiprocessing_logger� reset_multiprocessing_loggerr F�MP_LOGZceleryz celery.taskc C s | a dS )z8Set flag signifiying that we're inside a signal handler.N)�_in_sighandler)�value� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/utils/log.pyr ' s r c c s� t � } ttjjj�� �t�d �g }|D ]Z}zB|jD ]6}z || vrT|j V | � |� W q4 t yh Y q40 q4W q( t y� Y q(0 q(d S �N) �set�list�logging�Logger�manager� loggerDict�values� getLogger�handlers�stream�add�AttributeError)�seen�loggers�l�handlerr r r �iter_open_logger_fds- s � r) c c s* t d� zdV W t d� n t d� 0 dS )z5Context that records that we are in a signal handler.TNF)r r r r r r > s r �� c C sl | t � }}t|�D ]D}||kr& dS ||v r@td| j�d���|�|� |j}|s qhqtd|� ���dS )NTzLogger z parents recursivezLogger hierarchy exceeds F)r �range� RuntimeError�namer# �parent)r' �p�max�thisr% �_r r r � logger_isaH s � r3 c C s t || �s| |_|S r )r3 r. )Z parent_loggerZlogger_r r r �_using_logger_parent[ s r4 c C s. t | �}tj||jfvr*|tur*tt|�}|S )zGet logger by name.)� _get_loggerr �rootr. r r4 )r- r' r r r r a s r z celery.workerc C s& | t v rtd| �d���ttt| ��S )z#Get logger for task module by name.z Logger name z is reserved!)�RESERVED_LOGGER_NAMESr, r4 � task_loggerr )r- r r r r m s r c C s | r t | tj�s t| �� S | S )z$Convert level name/int to log level.)� isinstance�numbers�Integralr �upper)�levelr r r r t s r c s` e Zd ZdZe� jZed ed ed ed d�Zd� fd d � Z� fd d �Z � fd d�Z � Z S )r z5Logging formatter that adds colors based on severity.�blue�yellow�red�magenta)�DEBUG�WARNING�ERROR�CRITICALNTc s t � �|� || _d S r )�super�__init__� use_color)�self�fmtrH �� __class__r r rG � s zColorFormatter.__init__c s& |rt |t�st�� }t� �|�}|S r )r9 �tuple�sys�exc_inforF �formatException)rI �ei�rrK r r rP � s z ColorFormatter.formatExceptionc s" t � �|�}| j�|j�}|jdkr,t�� n|j}|�r| j�rzPz.t|t �rbt |t |���W W S t ||��W W S t y� t |� Y W S 0 W n� t �y } zh|j dd�t|�|� }|_|_ z(t � �|�W || |_ |_W Y d }~S || |_ |_0 W Y d }~n d }~0 0 nt |�S d S )Nr z <Unrepresentable {!r}: {!r}>)rF �format�colors�get� levelnamerO rN rH r9 �strr �UnicodeDecodeError� Exception�msg�type)rI �recordrZ �colorZeinfo�excZprev_msgrK r r rS � s, �� �(zColorFormatter.format)NT) �__name__� __module__� __qualname__�__doc__r �namesZCOLORSrT rG rP rS � __classcell__r r rK r r { s � r c @ sd e Zd ZdZdZdZdZejZ e � � Z ddd�Z dd� Zd d � Zd d � Zd d� Zdd� Zdd� ZdS )r z�Forward file object to :class:`logging.Logger` instance. Arguments: logger (~logging.Logger): Logger instance to forward to. loglevel (int, str): Log level to use when logging messages. �wNFc C s* || _ t|p| j jp| j�| _| �� d S r )�loggerr r= �loglevel�_safewrap_handlers)rI rf rg r r r rG � s zLoggingProxy.__init__c s dd� � � fdd�| j jD �S )Nc S s G dd� dt j�}|� j| _d S )Nc @ s e Zd Zdd� ZdS )zRLoggingProxy._safewrap_handlers.<locals>.wrap_handler.<locals>.WithSafeHandleErrorc S s* zt �d tj� W n ty$ Y n0 d S r )� traceback� print_excrN � __stderr__�OSError)rI r\ r r r � handleError� s z^LoggingProxy._safewrap_handlers.<locals>.wrap_handler.<locals>.WithSafeHandleError.handleErrorN)r_ r` ra rm r r r r �WithSafeHandleError� s rn )r �Handlerrm )r( rn r r r � wrap_handler� s z5LoggingProxy._safewrap_handlers.<locals>.wrap_handlerc s g | ] }� |��qS r r )�.0�h�rp r r � <listcomp>� � z3LoggingProxy._safewrap_handlers.<locals>.<listcomp>)rf r! �rI r rs r rh � s z LoggingProxy._safewrap_handlersc C s� t r"t|�}t|tjd� t|�S t| jdd�r4dS |r�| js�d| j_ z@t|�� d�}|r|| j � | j |� t|�W d| j_ S W d| j_ n d| j_ 0 dS )z Write message to logging object.)�file�recurse_protectionFr T� )r r �printrN rk �len�getattr�_thread�closedrx �rstriprf �logrg )rI �dataZ safe_datar r r �write� s" �zLoggingProxy.writec C s |D ]}| � |� qdS )z�Write list of strings to file. The sequence can be any iterable object producing strings. This is equivalent to calling :meth:`write` for each string. N)r� )rI �sequence�partr r r � writelines� s zLoggingProxy.writelinesc C s d S r r rv r r r �flush� s zLoggingProxy.flushc C s d| _ d S )NT)r~ rv r r r �close� s zLoggingProxy.closec C s dS )zHere for file support.Fr rv r r r �isatty s zLoggingProxy.isatty)N)r_ r` ra rb �moder- r~ r rD rg � threading�localr} rG rh r� r� r� r� r� r r r r r � s r c C s0 zddl m} W n ty" Y n 0 | �� S dS )z"Return the multiprocessing logger.r ��utilN)�billiardr� � ImportErrorr r� r r r r s r c C s8 zddl m} W n ty" Y n0 t| d�r4d| _dS )z$Reset multiprocessing logging setup.r r� �_loggerN)r� r� r� �hasattrr� r� r r r r s r c C s0 zddl m} W n ty" Y n 0 | �� S d S )Nr ��process)r� r� r� �current_processr� r r r r� s r� c C s" t t� dd �}|d ur || S |S )N�index)r| r� )�baser� r r r �current_process_index% s r� )r* )r )-rb r r: �osrN r� ri � contextlibr �typingr r Z kombu.logr r r5 Zkombu.utils.encodingr �termr �__all__Z_process_awarer �environrU r r7 r rf r r) r r3 r4 r8 Z worker_loggerr r � Formatterr r r r r� r� r r r r �<module> sF 7U
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка