Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/app/__pycache__/log.cpython-39.pyc
Ðазад
a t�hk# � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZmZ ddlmZ dd lmZmZmZmZmZmZ dd lmZ dd lm Z d Z ej � d d�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)�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__� �~/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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__5 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)r1 �hostname� )ZCELERY_LOG_LEVELZCELERY_LOG_FILE�always)�categoryT) r �setup_logging_subsystem�redirect_stdouts�os�environr �str�warnings�filterwarningsr r r, �captureWarnings)r r. �logfiler9 Zredirect_levelr1 r4 Zhandledr# r# r$ �setup< s � � z Logging.setup�celery.redirectedc C s. | j t|�|d� tjjdt|p"d�d� d S )N)r. �1r5 )ZCELERY_LOG_REDIRECTZCELERY_LOG_REDIRECT_LEVEL)�redirect_stdouts_to_loggerr r: r; r r< )r r. r r# r# r$ r9 M 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. r@ r r1 �celery� celery.taskrB �rE �loggerr. r@ r r1 )r1 r r5 )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+ r/ Zworker_hijack_root_logger�handlersr �_configure_loggerr r �ERRORZafter_setup_logger�setup_task_loggers�stream�AttributeError� IndexErrorr � isinstancer< r: r; r ) r r. r@ r r1 r4 �kwargsZ receivers�rootrT Z logfile_namer# r# r$ r8 V sb � ����� �z Logging.setup_logging_subsystemc K s2 |d ur.| j ||||fi |�� |r.|�|� d S r* )�setup_handlers�setLevel)r rI r@ r. r r1 rX r# r# r$ rQ � 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. rG � formatterNrH ) r r. r0 rL rZ r r r[ �int� propagater Zafter_setup_task_loggerrN )r r. r@ r r1 r^ rX rI r# r# r$ rS � 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 rI r. r` ra �proxyr# r# r$ rD � s z"Logging.redirect_stdouts_to_loggerc C s@ |d u r| j n|}| jjr dS |s*|d u r<|d u o:tj�� S |S )NF)r1 r+ Z IS_WINDOWSr_ ra �isatty)r r1 r@ r# r# r$ rL � s zLogging.supports_colorc C s t | �||�d�S )N)�enabled)r rL )r r@ 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 rI r@ r r1 r\ rX �handlerr# r# r$ rZ � 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 r@ r# r# r$ rf � s zLogging._detect_handlerc C s t dd� |jpg D ��S )Nc s s | ]}t |tj� V qd S r* )rW r, � NullHandler)�.0�hr# r# r$ � <genexpr>� s �z'Logging._has_handler.<locals>.<genexpr>)�anyrP �r rI 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_configuredrF c K s t |�S r* )r )r r rX r# r# r$ �get_default_logger� s zLogging.get_default_loggerc C s | j S r* �rK )r r# r# r$ rJ � s zLogging.already_setupc C s || _ d S r* rx )r Z was_setupr# r# r$ rJ � s )NNFr3 NN)NrB )NNNNN)NNNNF)NTT)NN)NN)N)rF )r% r& r' r( rK r2 rA r9 r8 rQ rS rD rL r r rZ rf ru re rw r rJ �setterr# r# r# r$ r - s: � � = � � � r )#r( r, r: r_ r= �logging.handlersr Zkombu.utils.encodingr rF r Z celery._stater Zcelery.exceptionsr r Z celery.localr 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"
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка