File: //usr/local/lib/python3.9/site-packages/celery/apps/__pycache__/beat.cpython-39.pyc
a
X>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. �:/usr/local/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