File: //usr/local/lib/python3.9/site-packages/celery/utils/__pycache__/log.cpython-39.pyc
a
X>h4" � @ 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 )z7Set flag signifying that we're inside a signal handler.N)�_in_sighandler)�value� r �:/usr/local/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 �names�COLORSrT 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 rg rh 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 rn r r r r �WithSafeHandleError� s ro )r �Handlerrn )r( ro r r r � wrap_handler� s z5LoggingProxy._safewrap_handlers.<locals>.wrap_handlerc s g | ] }� |��qS r r )�.0�h�rq r r �
<listcomp>� � z3LoggingProxy._safewrap_handlers.<locals>.<listcomp>)rg r! �rI r rt r ri � 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 rl �len�getattr�_thread�closedry �rstriprg �logrh )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 rw r r r �flush� s zLoggingProxy.flushc C s
d| _ d S )NT)r rw r r r �close� s zLoggingProxy.closec C s dS )zHere for file support.Fr rw r r r �isatty s zLoggingProxy.isatty)N)r_ r` ra rb �moder- r r rD rh � threading�localr~ rG ri 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� rj �
contextlibr �typingr r Z kombu.logr r r5 Zkombu.utils.encodingr Ztermr �__all__Z_process_awarer �environrU r r7 r rg r
r) r r3 r4 r8 Z
worker_loggerr r � Formatterr
r r r r� r� r r r r �<module> sF
7U