File: //home/arjun/projects/env/lib/python3.10/site-packages/celery/apps/__pycache__/beat.cpython-310.pyc
o
-we\ � @ 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< d4d5d d �Zd6d!d"�Z d7d8d$d%�Z
d6d&d'�Z d9d*d+�Z d6d,d-�Z
d9d.d/�Zd6d0d1�Zd:d2d3�ZdS );r zBeat as a service.Nr �app� �WARNF� max_interval�
int | None�
Celery | None�socket_timeout�int�pidfile�
str | None�no_color� bool | None�loglevel�str�logfile�schedule� scheduler�
scheduler_cls�redirect_stdouts�redirect_stdouts_level�quiet�bool�kwargsr �return�Nonec K s� |p| j | _ }| j j}|| _|| _|d|�| _|d| |
�| _|d| �| _|d| �| _|
| _|| _ || _
|| _ |j j
| j|d urC| n|d�| _
|| _t| jtj�s\t| j�� | _d S d S )N�beat_schedule_filename�beat_scheduler�worker_redirect_stdouts� 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. � r6 �I/home/arjun/projects/env/lib/python3.10/site-packages/celery/apps/beat.py�__init__. s4 �����z
Beat.__init__c C s> | j stt| j�dt� d���� | �� | �� | �� d S )Nz
celery beat vz
is starting.) r$ �printr r0 �cyanr � init_loader�set_process_title�start_scheduler�r5 r6 r6 r7 �runN s
� zBeat.run�colorizec C s> |d u r
| j d ur
| j }| jjj| j| j| j| j|d� d S )N)r@ )r r r/ �setupr r r" r# )r5 r@ r6 r6 r7 �
setup_loggingV s
�zBeat.setup_loggingc
C s� | j r t�| j � | j| j| j| j| jd�}| js t | �
|�� | � � | j r4t
�d| j � t�| j � z | �|� |�� W d S tyW } z t
jd|j|dd� � d }~ww )N)r r r! �schedule_filenamez$Setting default socket timeout to %rz beat raised exception %s: %rT)�exc_info)r r
�create_pidlock�Servicer r r! r r$ r9 �bannerrB r �logger�debug�socket�setdefaulttimeout�install_sync_handler�start� Exception�critical� __class__)r5 �service�excr6 r6 r7 r= ] s6 ��
���zBeat.start_schedulerrQ � beat.Servicec
C sB | j }t|�d|�d�|�d�|�d�|�d�|�| �|����S )Nz__ �-z
... __ z
_
)r0 r �blue�magenta�reset� startup_info)r5 rQ �cr6 r6 r7 rG x s ��z Beat.bannerc C s | j j�� | j �� d S �N)r �loader� init_worker�finalizer> r6 r6 r7 r; � s zBeat.init_loaderc C s` |j dd�}tj| j�� �� t�� jdd�| j pdt
| j t | jj
�t |�|jt|j�|jd� S )NT)�lazyr )� microsecondz[stderr]) �conninfo� timestampr r r[ r �scheduler_info�
hmax_intervalr )�
get_scheduler�STARTUP_INFO_FMT�formatr �
connection�as_urir �now�replacer r r r r[ �infor r )r5 rQ r r6 r6 r7 rX � s
�zBeat.startup_infoc C s8 dt jd v r dp
d}tjdd�t j|d � �d� d S )N�manager � � z celery beat� )rk )�sys�argvr
r< �join)r5 � arg_startr6 r6 r7 r< � s
�zBeat.set_process_titlec s" d � fdd� }t jj||d � d
S ) z;Install a `SIGTERM` + `SIGINT` handler saving the schedule.�signumr �framer r' r( c s � � � t� �rZ )�sync�
SystemExit)rt ru �rQ r6 r7 �_sync� s z(Beat.install_sync_handler.<locals>._sync)�SIGTERM�SIGINTN)rt r ru r r' r( )r
�signals�update)r5 rQ ry r6 rx r7 rL � s zBeat.install_sync_handler)
NNr NNr NNNNNNF) r r r r r r r r r r r r r r r r r r r! r r" r r# r r$ r% r& r r' r( )r' r( rZ )r@ r r' r( )rQ rS r' r )rQ rS r' r( )�__name__�
__module__� __qualname__�__doc__r rF r �__annotations__r8 r? rB r= rG r; rX r< rL r6 r6 r6 r7 r ( s*
�
r ) r� �
__future__r r2 rJ rp r �signalr �typesr �typingr �celeryr r r r
�celery.utils.importsr �celery.utils.logr r
�celery.utils.timer �__all__�stripre rH r r6 r6 r6 r7 �<module> s& �