File: //usr/local/lib/python3.9/site-packages/celery/app/__pycache__/log.cpython-39.pyc
a
X>h�# � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
Z
ddl m Z ddl
mZmZ ddlmZ dd lmZ dd
lmZmZmZmZmZmZ dd lm Z dd l m Z d
Z ej �!dd�Z"G dd� de�Z#G dd� d�Z$dS )z�Logging configuration.
The Celery instances logging section: ``Celery.log``.
Sets up logging for the worker and other programs,
redirects standard outs, colors log output, patches logging
related compatibility fixes, and so on.
� N)�WatchedFileHandler)�set_default_encoding_file)�signals)�get_current_task)�CDeprecationWarning�CPendingDeprecationWarning)�class_property)�isatty)�ColorFormatter� LoggingProxy�
get_logger�get_multiprocessing_logger�mlevel� reset_multiprocessing_logger)� node_format)�colored)�
TaskFormatter�Logging�MP_LOGFc s e Zd ZdZ� fdd�Z� ZS )r z1Formatter for tasks, adding the task name and id.c sP t � }|r(|jr(|jj|jj|jd� n |j�dd� |j�dd� t� �|�S )N)�task_id� task_namer z???r ) r �request�__dict__�update�id�name�
setdefault�super�format)�self�record�task�� __class__� �8/usr/local/lib/python3.9/site-packages/celery/app/log.pyr # s
�zTaskFormatter.format)�__name__�
__module__� __qualname__�__doc__r �
__classcell__r$ r$ r" r% r s r c @ s� e Zd ZdZdZdd� Zd'dd�Zd(d
d �Zd)d d
�Zdd� Z d*dd�Z
d+dd�Z d,dd�Z d-dd�Z
efdd�Zd.dd �Zd d � Zd d � Zd/d"d#�Zed$d%� �Zejd&d%� �ZdS )0r z$Application logging setup (app.log).Fc C s: || _ ttj�| _| j jj| _| j jj| _ | j jj
| _ d S �N) �appr �logging�WARN�loglevel�confZworker_log_formatr Zworker_task_log_format� task_formatZworker_log_color�colorize)r r, r$ r$ r% �__init__6 s
zLogging.__init__N�WARNINGc C s~ t |�}| j||||d�}|s,|r,| �|� tjj|r>t|�nd|rLt|�ndd� tjdt d� tjdt
d� t � d� |S )N)r2 �hostname� )ZCELERY_LOG_LEVELZCELERY_LOG_FILE�always)�categoryT)
r �setup_logging_subsystem�redirect_stdouts�os�environr �str�warnings�filterwarningsr r r- �captureWarnings)r r/ �logfiler: Zredirect_levelr2 r5 Zhandledr$ r$ r% �setup= s �
�
z
Logging.setup�celery.redirectedc C s. | j t|�|d� tjjdt|p"d�d� d S )N)r/ �1r6 )ZCELERY_LOG_REDIRECTZCELERY_LOG_REDIRECT_LEVEL)�redirect_stdouts_to_loggerr r; r< r r= )r r/ r r$ r$ r% r: N s �
�zLogging.redirect_stdoutsc K sj | j r
d S |r |r t||�}dt_t|p,| j�}|p8| j}| �||�}t� t j
j d ||||d�}|�st �
� }| jjjr�g |_g td�_g td�_g td�_| j|||||fi |�� | jt� |tr�|nt j||fi |�� t jj d |||||d� | j|||d� zt �
� jd j} W n ttf�y2 Y n
0 t | � t |t ��rL|nd }
t j j!t |�|
|d
� |S ) NT)�senderr/ rA r r2 �celery� celery.taskrC �rF �loggerr/ rA r r2 )r2 r r6 )Z_MP_FORK_LOGLEVEL_Z_MP_FORK_LOGFILE_Z_MP_FORK_LOGFORMAT_)"�
already_setupr r �_setupr r/ r �supports_colorr r �
setup_logging�sendr- � getLoggerr, r0 Zworker_hijack_root_logger�handlersr �_configure_loggerr
r �ERRORZafter_setup_logger�setup_task_loggers�stream�AttributeError�
IndexErrorr �
isinstancer= r; r< r ) r r/ rA r r2 r5 �kwargsZ receivers�rootrU Z logfile_namer$ r$ r% r9 W sb
�
����� �z Logging.setup_logging_subsystemc K s2 |d ur.| j ||||fi |�� |r.|�|� d S r+ )�setup_handlers�setLevel)r rJ rA r/ r r2 rY r$ r$ r% rR � s
��zLogging._configure_loggerc K st t |p
| j�}|p| j}| �||�}| jtd�|||fdti|��}|�|� t|�|_ t
j j d|||||d� |S )z�Setup the task logger.
If `logfile` is not specified, then `sys.stderr` is used.
Will return the base task logger object.
rH � formatterNrI )
r r/ r1 rM r[ r r r\ �int� propagater Zafter_setup_task_loggerrO )r r/ rA r r2 r_ rY rJ r$ r$ r% rT � s&
���
�zLogging.setup_task_loggersTc C s" t ||�}|r|t_|r |t_|S )a Redirect :class:`sys.stdout` and :class:`sys.stderr` to logger.
Arguments:
logger (logging.Logger): Logger instance to redirect to.
loglevel (int, str): The loglevel redirected message
will be logged as.
)r �sys�stdout�stderr)r rJ r/ ra rb �proxyr$ r$ r% rE � s
z"Logging.redirect_stdouts_to_loggerc C s@ |d u r| j n|}| jjr dS |s*|d u r<|d u o:ttj�S |S )NF)r2 r, Z
IS_WINDOWSr r` rb )r r2 rA r$ r$ r% rM � s zLogging.supports_colorc C s t | �||�d�S )N)�enabled)r rM )r rA rd r$ r$ r% r � s zLogging.coloredc K s8 | � |�r|S | �|�}|�|||d�� |�|� |S )N)Z use_color)�_is_configured�_detect_handler� setFormatter�
addHandler)r rJ rA r r2 r] rY �handlerr$ r$ r% r[ � s
zLogging.setup_handlersc C s2 |du rt jn|}t|d�r&t�|�S t|dd�S )z@Create handler from filename, an open stream or `None` (stderr).N�writezutf-8)�encoding)r` �
__stderr__�hasattrr- �
StreamHandlerr )r rA r$ r$ r% rf � s
zLogging._detect_handlerc C s t dd� |jpg D ��S )Nc s s | ]}t |tj� V qd S r+ )rX r- � NullHandler)�.0�hr$ r$ r% � <genexpr>� s �z'Logging._has_handler.<locals>.<genexpr>)�anyrQ �r rJ r$ r$ r% � _has_handler� s �zLogging._has_handlerc C s | � |�ot|dd� S )NZ_rudimentary_setupF)ru �getattrrt r$ r$ r% re � s �zLogging._is_configuredrG c K s t |�S r+ )r )r r rY r$ r$ r% �get_default_logger� s zLogging.get_default_loggerc C s | j S r+ �rL )r r$ r$ r% rK � s zLogging.already_setupc C s
|| _ d S r+ rx )r Z was_setupr$ r$ r% rK � s )NNFr4 NN)NrC )NNNNN)NNNNF)NTT)NN)NN)N)rG )r& r' r( r) rL r3 rB r: r9 rR rT rE rM r r
r[ rf ru re rw r rK �setterr$ r$ r$ r% r . s: �
�
= �
�
�
r )%r) r- r; r` r> �logging.handlersr Zkombu.utils.encodingr rG r Z
celery._stater Zcelery.exceptionsr r Z celery.localr Zcelery.platformsr Zcelery.utils.logr
r r r
r r Zcelery.utils.nodenamesr Zcelery.utils.termr �__all__r< �getr r r r$ r$ r$ r% �<module> s$