Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/__pycache__/beat.cpython-39.pyc
Ðазад
a t�h�_ � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZ ddlmZmZ ddlmZ ddlmZ dd lmZ dd lmZmZ dd lm Z d d l m Z m Z m Z d dl!m"Z" d dl#m$Z$m%Z% d dl&m'Z' d dl(m)Z)m*Z* d dl+m,Z,m-Z- d dl.m/Z/m0Z0 dZ1e dd�Z2e,e3�Z4e4j5e4j6e4j7e4j8f\Z5Z6Z7Z8dZ9G dd� de:�Z;G dd� d�Z<eG d d � d ��Z=d d � Z>d d!� Z?G d"d#� d#�Z@G d$d%� d%e@�ZAG d&d'� d'�ZBG d(d)� d)e�ZCz e� W n eD�y� dZEY n0 G d*d+� d+e�ZEd.d,d-�ZFdS )/z The periodic task scheduler.� N)�timegm)� namedtuple)�total_ordering)�Event�Thread)�ensure_multiprocessing)� reset_signals)�Process)�maybe_evaluate�reprcall)�cached_property� )� __version__� platforms�signals)�reraise)�crontab�maybe_schedule)�is_numeric_value)�load_extension_class_names�symbol_by_name)� get_logger�iter_open_logger_fds)�humanize_seconds�maybe_make_aware)�SchedulingError� ScheduleEntry� Scheduler�PersistentScheduler�Service�EmbeddedService�event_t)�time�priority�entryi, c @ s e Zd ZdZdS )r z*An error occurred while scheduling a task.N)�__name__� __module__� __qualname__�__doc__� r) r) �{/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/beat.pyr , s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � BeatLazyFuncao A lazy function declared in 'beat_schedule' and called before sending to worker. Example: beat_schedule = { 'test-every-5-minutes': { 'task': 'test', 'schedule': 300, 'kwargs': { "current": BeatCallBack(datetime.datetime.now) } } } c O s || _ ||d�| _d S )N)�args�kwargs�Z_funcZ _func_params)�self�funcr, r- r) r) r* �__init__A s �zBeatLazyFunc.__init__c C s | � � S �N)�delay�r/ r) r) r* �__call__H s zBeatLazyFunc.__call__c C s | j | jd i | jd ��S )Nr, r- r. r4 r) r) r* r3 K s zBeatLazyFunc.delayN)r% r& r' r( r1 r5 r3 r) r) r) r* r+ 0 s r+ c @ s� e Zd ZdZdZdZdZdZdZdZ dZ d dd�Z dd � Z e Z d d d �Ze ZZd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� ZdS ) r a� An entry in the scheduler. Arguments: name (str): see :attr:`name`. schedule (~celery.schedules.schedule): see :attr:`schedule`. args (Tuple): see :attr:`args`. kwargs (Dict): see :attr:`kwargs`. options (Dict): see :attr:`options`. last_run_at (~datetime.datetime): see :attr:`last_run_at`. total_run_count (int): see :attr:`total_run_count`. relative (bool): Is the time relative to when the server starts? Nr r) Fc C sb | | _ || _|| _|| _|r |ni | _|r.|ni | _t|| | j d�| _|pP| �� | _ |pZd| _ d S )N)�appr ) r6 �name�taskr, r- �optionsr �schedule� default_now� last_run_at�total_run_count) r/ r7 r8 r< r= r: r, r- r9 �relativer6 r) r) r* r1 s s zScheduleEntry.__init__c C s | j r| j �� S | j�� S r2 )r: �nowr6 r4 r) r) r* r; � s zScheduleEntry.default_nowc C s( | j f i t| |p| �� | jd d���S )z8Return new instance, with date and count fields updated.r )r< r= )� __class__�dictr; r= )r/ r< r) r) r* �_next_instance� s �z ScheduleEntry._next_instancec C s* | j | j| j| j| j| j| j| j| jffS r2 ) r@ r7 r8 r< r= r: r, r- r9 r4 r) r) r* � __reduce__� s �zScheduleEntry.__reduce__c C s& | j �|j|j|j|j|jd�� dS )z�Update values from another entry. Will only update "editable" fields: ``task``, ``schedule``, ``args``, ``kwargs``, ``options``. )r8 r: r, r- r9 N)�__dict__�updater8 r: r, r- r9 �r/ �otherr) r) r* rE � s �zScheduleEntry.updatec C s | j �| j�S )z.See :meth:`~celery.schedules.schedule.is_due`.)r: �is_duer< r4 r) r) r* rH � s zScheduleEntry.is_duec C s t t| ��� �S r2 )�iter�vars�itemsr4 r) r) r* �__iter__� s zScheduleEntry.__iter__c C s, dj | t| j| jpd| jp i �t| �jd�S )Nz%<{name}: {0.name} {call} {0.schedule}r) )�callr7 )�formatr r8 r, r- �typer% r4 r) r) r* �__repr__� s �zScheduleEntry.__repr__c C s t |t�rt| �t|�k S tS r2 )� isinstancer �id�NotImplementedrF r) r) r* �__lt__� s zScheduleEntry.__lt__c C s( dD ] }t | |�t ||�kr dS qdS )N)r8 r, r- r9 r: FT)�getattr)r/ rG �attrr) r) r* �editable_fields_equal� s z#ScheduleEntry.editable_fields_equalc C s | � |�S )z�Test schedule entries equality. Will only compare "editable" fields: ``task``, ``schedule``, ``args``, ``kwargs``, ``options``. )rW rF r) r) r* �__eq__� s zScheduleEntry.__eq__) NNNNNr) NNFN)N)r% r& r' r( r7 r: r, r- r9 r< r= r1 r; Z _default_nowrB �__next__�nextrC rE rH rL rP rT rW rX r) r) r) r* r O s0 � r c C s | sg S dd� | D �S )Nc S s g | ]}t |t�r|� n|�qS r) �rQ r+ )�.0�vr) r) r* � <listcomp>� s �z(_evaluate_entry_args.<locals>.<listcomp>r) )� entry_argsr) r) r* �_evaluate_entry_args� s �r` c C s | si S dd� | � � D �S )Nc S s& i | ] \}}|t |t�r |� n|�qS r) r[ )r\ �kr] r) r) r* � <dictcomp>� s �z*_evaluate_entry_kwargs.<locals>.<dictcomp>)rK )� entry_kwargsr) r) r* �_evaluate_entry_kwargs� s �rd c @ s@ e Zd ZdZeZdZeZdZ dZ dZ dZ e Z d>dd�Zdd � Zd?d d �Zd@d d�Zdd� Zefdd�Zeejfdd�Zeeejejfdd�Z dd� Z dd� Z dd � Z dAd d �Z d d!� Z!d"d#� Z"d$d%� Z#d&d'� Z$d(d)� Z%d*d+� Z&d,d-� Z'd.d/� Z(d0d1� Z)d2d3� Z*d4d5� Z+d6d7� Z,e-e+e,�Ze.d8d9� �Z/e.d:d;� �Z0e-d<d=� �Z1dS )Br a� Scheduler for periodic tasks. The :program:`celery beat` program may instantiate this class multiple times for introspection purposes, but then with the ``lazy`` argument set. It's important for subclasses to be idempotent when this argument is set. Arguments: schedule (~celery.schedules.schedule): see :attr:`schedule`. max_interval (int): see :attr:`max_interval`. lazy (bool): Don't set up the schedule. N� r Fc K sp || _ t|d u ri n|�| _|p,|jjp,| j| _|p:|jj| _d | _d | _ |d u rZ|jj n|| _ |sl| � � d S r2 ) r6 r �data�conf�beat_max_loop_interval� max_intervalZamqp�Producer�_heap�old_schedulersZbeat_sync_every�sync_every_tasks�setup_schedule)r/ r6 r: ri rj �lazyrm r- r) r) r* r1 � s ���zScheduler.__init__c C sJ i }| j jjr<| j jjs<d|vr<dtddd�ddid�|d< | �|� d S )Nzcelery.backend_cleanup�0�4�*�expiresi�� )r8 r: r9 )r6 rg Zresult_expires�backendZsupports_autoexpirer �update_from_dict)r/ rf �entriesr) r) r* �install_default_entries s � � z!Scheduler.install_default_entriesc C s� t d|j|j� z| j||dd�}W n8 ty\ } z td|t�� dd� W Y d }~n6d }~0 0 |r~t|d�r~t d|j|j � n t d |j� d S ) Nz#Scheduler: Sending due task %s (%s)F)�producer�advancezMessage Error: %s %sT��exc_inforR z%s sent. id->%sz%s sent.) �infor7 r8 � apply_async� Exception�error� traceback� format_stack�hasattr�debugrR )r/ r$ rx �result�excr) r) r* � apply_entry s � zScheduler.apply_entry�{�G�z��c C s |r|dkr|| S |S )Nr r) )r/ �nZdriftr) r) r* �adjust" s zScheduler.adjustc C s |� � S r2 )rH )r/ r$ r) r) r* rH ' s zScheduler.is_duec C s4 | j }t|�� �}||�� �|jd ||�p0d S )z9Return a utc timestamp, make sure heapq in correct order.g ��.Ar )r� r r; � utctimetuple� microsecond)r/ r$ �next_time_to_run�mktimer� Zas_nowr) r) r* �_when* s � �zScheduler._whenc C s\ d}g | _ | j�� D ]8}|�� \}}| j �|| �||r:dn|�pBd||�� q|| j � dS )z:Populate the heap with the data contained in the schedule.� r N)rk r: �valuesrH �appendr� )r/ r! �heapifyr# r$ rH Znext_call_delayr) r) r* � populate_heap4 s ��zScheduler.populate_heapc C s� | j }| j}| jdu s&| �| j| j�s<t�| j�| _| �� | j}|sJ|S |d }|d } | �| �\} } | r�||�} | |u r�| � | �} | j | | j d� |||| � | | �|d | �� dS ||| � || d |�S || �}|t |�r�|n||�S )z�Run a tick - one iteration of the scheduler. Executes one due task per call. Returns: float: preferred delay in seconds for next call. Nr � )rx r )r� ri rk �schedules_equalrl r: �copyr� rH �reserver� rx r� r )r/ r! �min�heappop�heappushr� ri �H�eventr$ rH r� �verifyZ next_entryZadjusted_next_time_to_runr) r) r* �tickD s8 � � �zScheduler.tickc C s� || u rd u r n ndS |d u s,|d u r0dS t |�� �t |�� �krLdS |�� D ]*\}}|�|�}|sp dS ||krT dS qTdS )NTF)�set�keysrK �get)r/ Z old_schedulesZ new_schedulesr7 Z old_entry� new_entryr) r) r* r� l s zScheduler.schedules_equalc C s. | j p,t�� | j | jkp,| jo,| j| jkS r2 )� _last_syncr" � monotonic� sync_everyrm �_tasks_since_syncr4 r) r) r* � should_sync{ s � �zScheduler.should_syncc C s t |� }| j|j< |S r2 )rZ r: r7 )r/ r$ r� r) r) r* r� � s zScheduler.reserveTc K sR |r| � |�n|}| jj�|j�}�zz�t|j�}t|j�}|r||j ||fd|i|j ��W W | j d7 _ | � � rz| � � S | j|j||fd|i|j ��W W | j d7 _ | � � r�| � � S W nH t�y } z.tttdj||d��t�� d � W Y d }~n d }~0 0 W | j d7 _ | � � �rN| � � n"| j d7 _ | � � �rL| � � 0 d S )Nrx r z-Couldn't apply scheduled task {0.name}: {exc})r� r� )r� r6 �tasksr� r8 r` r, rd r- r} r9 r� r� �_do_sync� send_taskr~ r r rN �sysr{ ) r/ r$ rx ry r- r8 r_ rc r� r) r) r* r} � sL �� ������ � � zScheduler.apply_asyncc O s | j j|i |��S r2 )r6 r� �r/ r, r- r) r) r* r� � s zScheduler.send_taskc C s | � | j� | �| jjj� d S r2 )rw rf � merge_inplacer6 rg � beat_scheduler4 r) r) r* rn � s zScheduler.setup_schedulec C s< z$t d� | �� W t�� | _d| _nt�� | _d| _0 d S )Nz beat: Synchronizing schedule...r )r� �syncr" r� r� r� r4 r) r) r* r� � s � zScheduler._do_syncc C s d S r2 r) r4 r) r) r* r� � s zScheduler.syncc C s | � � d S r2 )r� r4 r) r) r* �close� s zScheduler.closec K s& | j f d| ji|��}|| j|j< |S )Nr6 )�Entryr6 r: r7 )r/ r- r$ r) r) r* �add� s z Scheduler.addc C s4 t || j�r| j|_|S | jf i t||| jd���S �N)r7 r6 )rQ r� r6 rA )r/ r7 r$ r) r) r* � _maybe_entry� s zScheduler._maybe_entryc s" � j �� fdd�|�� D �� d S )Nc s i | ]\}}|� � ||��qS r) )r� )r\ r7 r$ r4 r) r* rb � s �z.Scheduler.update_from_dict.<locals>.<dictcomp>)r: rE rK )r/ Zdict_r) r4 r* ru � s �zScheduler.update_from_dictc C s� | j }t|�t|� }}||A D ]}|�|d � q |D ]F}| jf i t|| || jd���}|�|�rt|| �|� q6|||< q6d S r� )r: r� �popr� rA r6 r� rE )r/ �br: �A�B�keyr$ r) r) r* r� � s zScheduler.merge_inplacec C s dd� }| j �|| jjj�S )Nc S s t d| |� d S )Nz9beat: Connection error: %s. Trying again in %s seconds...)r )r� �intervalr) r) r* �_error_handler� s �z3Scheduler._ensure_connected.<locals>._error_handler)� connectionZensure_connectionr6 rg Z broker_connection_max_retries)r/ r� r) r) r* �_ensure_connected� s �zScheduler._ensure_connectedc C s | j S r2 �rf r4 r) r) r* � get_schedule� s zScheduler.get_schedulec C s || _ d S r2 r� �r/ r: r) r) r* � set_schedule� s zScheduler.set_schedulec C s | j �� S r2 )r6 Zconnection_for_writer4 r) r) r* r� � s zScheduler.connectionc C s | j | �� dd�S )NF)Z auto_declare)rj r� r4 r) r) r* rx � s zScheduler.producerc C s dS )N� r) r4 r) r) r* r| � s zScheduler.info)NNNFN)N)r� )NT)2r% r& r' r( r r� r: �DEFAULT_MAX_INTERVALri r� rm r� r� �loggerr1 rw r� r� rH r r� r! �heapqr� r� r� r� r� r� r� r� r� r} r� rn r� r� r� r� r� ru r� r� r� r� �propertyr r� rx r| r) r) r) r* r � sX � � ( r c s� e Zd ZdZeZdZdZ� fdd�Zdd� Z dd � Z d d � Z d d � Z dd� Z dd� Zdd� Zeee�Zdd� Zdd� Zedd� �Z� ZS )r z+Scheduler backed by :mod:`shelve` database.)r� z.dbz.datz.bakz.dirNc s" |� d�| _t� j|i |�� d S )N�schedule_filename)r� r� �superr1 r� �r@ r) r* r1 � s z PersistentScheduler.__init__c C sL | j D ]@}t�tj�� t�| j| � W d � q1 s<0 Y qd S r2 )�known_suffixesr Z ignore_errno�errno�ENOENT�os�remover� )r/ �suffixr) r) r* � _remove_db s z PersistentScheduler._remove_dbc C s | j j| jdd�S )NT)Z writeback)� persistence�openr� r4 r) r) r* �_open_schedule s z"PersistentScheduler._open_schedulec C s" t d| j|dd� | �� | �� S )Nz'Removing corrupted schedule file %r: %rTrz )r r� r� r� )r/ r� r) r) r* � _destroy_open_corrupted_schedule s �z4PersistentScheduler._destroy_open_corrupted_schedulec C sF z| � � | _| j�� W n0 tyH } z| �|�| _W Y d }~n d }~0 0 | �� | jjj}| j� d�}|d ur�||kr�t d||� | j� � | jjj }| j� d�}|d ur�||kr�ddd�}t d|| || � | j� � | j� di �}| �| jjj� | �| j� | j�t||d �� | �� td d �d d � |�� D �� � d S )N�tzz%Reset: Timezone changed from %r to %r� utc_enabled�enabled�disabled)TFz Reset: UTC changed from %s to %srv )r r� r� zCurrent schedule: � c s s | ]}t |�V qd S r2 )�repr)r\ r$ r) r) r* � <genexpr>4 s z5PersistentScheduler.setup_schedule.<locals>.<genexpr>)r� �_storer� r~ r� �_create_scheduler6 rg �timezoner� �warning�clearZ enable_utc� setdefaultr� r� rw r: rE r r� r� �joinr� )r/ r� r� Z stored_tz�utcZ stored_utc�choicesrv r) r) r* rn s> " � ��z"PersistentScheduler.setup_schedulec C s� dD ]�}z| j d W nl tttfy� zi | j d< W nD tttfy| } z&| �|�| _ W Y d }~Y qW Y d }~n d }~0 0 Y nZ0 d| j vr�td� | j �� n:d| j vr�td� | j �� n d| j vr�td� | j �� q�qd S ) N)r r� rv r z+DB Reset: Account for new __version__ fieldr� z"DB Reset: Account for new tz fieldr� z+DB Reset: Account for new utc_enabled field)r� �KeyError�UnicodeDecodeError� TypeErrorr� r� r� )r/ �_r� r) r) r* r� 7 s& * z$PersistentScheduler._create_schedulec C s | j d S �Nrv �r� r4 r) r) r* r� N s z PersistentScheduler.get_schedulec C s || j d< d S r� r� r� r) r) r* r� Q s z PersistentScheduler.set_schedulec C s | j d ur| j �� d S r2 )r� r� r4 r) r) r* r� U s zPersistentScheduler.syncc C s | � � | j�� d S r2 )r� r� r� r4 r) r) r* r� Y s zPersistentScheduler.closec C s d| j � �S )Nz . db -> )r� r4 r) r) r* r| ] s zPersistentScheduler.info)r% r& r' r( �shelver� r� r� r1 r� r� r� rn r� r� r� r� r: r� r� r| � __classcell__r) r) r� r* r � s" & r c @ sX e Zd ZdZeZddd�Zdd� Zddd �Zd d � Z dd d �Z ddd�Z e dd� �Z dS )r z Celery periodic task service.Nc C sB || _ |p|jj| _|p | j| _|p*|jj| _t� | _t� | _ d S r2 ) r6 rg rh ri � scheduler_clsZbeat_schedule_filenamer� r � _is_shutdown� _is_stopped)r/ r6 ri r� r� r) r) r* r1 g s � �zService.__init__c C s | j | j| j| j| jffS r2 )r@ ri r� r� r6 r4 r) r) r* rC s s �zService.__reduce__Fc C s� t d� tdt| jj�� tjj| d� |rDtjj| d� t � d� z�zV| j � � s�| j� � }|rH|dkrHtdt|dd�� t�|� | j�� rH| j�� qHW n ttfy� | j �� Y n0 W | �� n | �� 0 d S ) Nzbeat: Starting...z#beat: Ticking with max interval->%s)Zsenderz celery beatg zbeat: Waking up %s.zin )�prefix)r| r� r � schedulerri r Z beat_init�sendZbeat_embedded_initr Zset_process_titler� �is_setr� r" �sleepr� r� �KeyboardInterrupt� SystemExitr� r� )r/ �embedded_processr� r) r) r* �startw s* � � z Service.startc C s | j �� | j�� d S r2 )r� r� r� r� r4 r) r) r* r� � s z Service.syncc C s$ t d� | j�� |o | j�� d S )Nzbeat: Shutting down...)r| r� r� r� �wait)r/ r� r) r) r* �stop� s z Service.stop�celery.beat_schedulersc C s0 | j }tt|��}t| j|d�| j|| j|d�S )N)�aliases)r6 r� ri ro )r� rA r r r� r6 ri )r/ ro Zextension_namespace�filenamer� r) r) r* � get_scheduler� s �zService.get_schedulerc C s | � � S r2 )r� r4 r) r) r* r� � s zService.scheduler)NNN)F)F)Fr� )r% r& r' r( r r� r1 rC r� r� r� r� r r� r) r) r) r* r b s � � r c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )� _Threadedz(Embedded task scheduler using threading.c s2 t � �� || _t|fi |��| _d| _d| _d S )NT�Beat)r� r1 r6 r �service�daemonr7 �r/ r6 r- r� r) r* r1 � s z_Threaded.__init__c C s | j �� | j�� d S r2 )r6 � set_currentr r� r4 r) r) r* �run� s z _Threaded.runc C s | j jdd� d S )NT)r� )r r� r4 r) r) r* r� � s z_Threaded.stop)r% r& r' r( r1 r r� r� r) r) r� r* r� � s r� c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )�_Processc s, t � �� || _t|fi |��| _d| _d S )Nr )r� r1 r6 r r r7 r r� r) r* r1 � s z_Process.__init__c C sP t dd� t�tjtjtjgtt� � � | j � � | j � � | j j dd� d S )NF)�fullT)r� )r r Zclose_open_fdsr� � __stdin__� __stdout__� __stderr__�listr r6 � set_defaultr r r� r4 r) r) r* r � s �� z _Process.runc C s | j �� | �� d S r2 )r r� � terminater4 r) r) r* r� � s z _Process.stop)r% r& r' r1 r r� r� r) r) r� r* r � s r c K s< |� dd�stdu r(t| fddi|��S t| fd|i|��S )z�Return embedded clock service. Arguments: thread (bool): Run threaded instead of as a separate process. Uses :mod:`multiprocessing` by default, if available. �threadFNri r )r� r r� )r6 ri r- r) r) r* r � s r )N)Gr( r� r� r� r� r� r� r" r� �calendarr � collectionsr � functoolsr � threadingr r Zbilliardr Zbilliard.commonr Zbilliard.contextr Zkombu.utils.functionalr r Zkombu.utils.objectsr r� r r r � exceptionsr Z schedulesr r Zutils.functionalr Z utils.importsr r Z utils.logr r Z utils.timer r �__all__r! r% r� r� r| r r� r� r~ r r+ r r` rd r r r r� �NotImplementedErrorr r r) r) r) r* �<module> sb � w kF
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка