Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/apps/__pycache__/beat.cpython-39.pyc
Ðазад
a t�h\ � @ s� d Z ddlmZ ddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZmZmZmZ dd lmZ dd lmZmZ dd lmZ d Zd �� Zed�Z G dd� d�Z dS )z�Beat command-line program. This module is the 'program-version' of :mod:`celery.beat`. It does everything necessary to run that module as an actual application, like installing signal handlers and so on. � )� annotationsN)�datetime)�Signals)� FrameType)�Any)�VERSION_BANNER�Celery�beat� platforms)�qualname)� LOG_LEVELS� get_logger)�humanize_seconds)�Beatz� LocalTime -> {timestamp} Configuration -> . broker -> {conninfo} . loader -> {loader} . scheduler -> {scheduler} {scheduler_info} . logfile -> {logfile}@%{loglevel} . maxinterval -> {hmax_interval} ({max_interval}s) z celery.beatc @ s� e Zd ZU dZejZdZded< d(dd d d d d d d d d d d dddd�dd�Zdd�dd�Z d)d dd�dd�Z dd�dd�Z d d d �d d �Z dd�d d!�Z d d d �d"d#�Zdd�d$d%�Zd dd �d&d'�ZdS )*r zBeat as a service.Nr �app� �WARNFz int | Nonez Celery | None�intz str | Nonez bool | None�str�boolr �None)� max_intervalr �socket_timeout�pidfile�no_color�loglevel�logfile�schedule� scheduler� scheduler_cls�redirect_stdouts�redirect_stdouts_level�quiet�kwargs�returnc K s� |p| j | _ }| j j}|| _|| _|d|�| _|d| | �| _|d| �| _|d| �| _| | _|| _ || _ || _ |j j | j|d ur�| n|d�| _ || _t| jtj�s�t| j�� | _d S )NZbeat_schedule_filenameZbeat_schedulerZworker_redirect_stdoutsZ worker_redirect_stdouts_level)�enabled)r �eitherr r r r r r! r" r r r �log�coloredr � isinstance�numbers�Integralr �upper)�selfr r r r r r r r r r r r! r" r# r& � r. ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/apps/beat.py�__init__. s2 ����z Beat.__init__)r$ c C s> | j s"tt| j�dt� d���� | �� | �� | �� d S )Nz celery beat vz is starting.) r" �printr r( �cyanr � init_loader�set_process_title�start_scheduler�r- r. r. r/ �runN s �zBeat.run)�colorizer$ c C s> |d u r| j d ur| j }| jjj| j| j| j| j|d� d S )N)r8 )r r r' �setupr r r r! )r- r8 r. r. r/ � setup_loggingV s �zBeat.setup_loggingc C s� | j rt�| j � | j| j| j| j| jd�}| js@t | � |�� | � � | j rht �d| j � t�| j � z| �|� |�� W n: ty� } z"t jd|j|dd� � W Y d }~n d }~0 0 d S )N)r r r Zschedule_filenamez$Setting default socket timeout to %rz beat raised exception %s: %rT)�exc_info)r r Zcreate_pidlock�Servicer r r r r" r1 �bannerr: r �logger�debug�socket�setdefaulttimeout�install_sync_handler�start� Exception�critical� __class__)r- �service�excr. r. r/ r5 ] s2 �� �zBeat.start_schedulerz beat.Service)rG r$ c C sB | j }t|�d|�d�|�d�|�d�|�d�|�| �|����S )Nz__ �-z ... __ z _ )r( r �blue�magenta�reset� startup_info)r- rG �cr. r. r/ r= x s ��z Beat.bannerc C s | j j�� | j �� d S �N)r �loaderZ init_worker�finalizer6 r. r. r/ r3 � s zBeat.init_loaderc C s` |j dd�}tj| j�� �� t�� jdd�| j p2dt | j t | jj �t |�|jt|j�|jd� S )NT)Zlazyr )� microsecondz[stderr]) Zconninfo� timestampr r rP r Zscheduler_infoZ hmax_intervalr )Z get_scheduler�STARTUP_INFO_FMT�formatr � connection�as_urir �now�replacer r r r rP �infor r )r- rG r r. r. r/ rM � s �zBeat.startup_infoc C s8 dt jd v rdpd}tjdd�t j|d � �d� d S )NZmanager � � z celery beat� )rZ )�sys�argvr r4 �join)r- Z arg_startr. r. r/ r4 � s �zBeat.set_process_titlec s* dddd�� fdd� }t jj||d� dS ) z;Install a `SIGTERM` + `SIGINT` handler saving the schedule.r r r )�signum�framer$ c s � � � t� �d S rO )�sync� SystemExit)ra rb �rG r. r/ �_sync� s z(Beat.install_sync_handler.<locals>._sync)�SIGTERM�SIGINTN)r Zsignals�update)r- rG rf r. re r/ rB � s zBeat.install_sync_handler) NNr NNr NNNNNNF)N)�__name__� __module__� __qualname__�__doc__r r< r �__annotations__r0 r7 r: r5 r= r3 rM r4 rB r. r. r. r/ r ( s( �, r ) rm � __future__r r* r@ r^ r �signalr �typesr �typingr Zceleryr r r r Zcelery.utils.importsr Zcelery.utils.logr r Zcelery.utils.timer �__all__�striprT r> r r. r. r. r/ �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка