Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/__pycache__/base.cpython-39.pyc
Ðазад
a k�h� � @ s� d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlmZm Z m Z d dlm Z d dl m Z mZmZmZ G dd� de�ZG d d � d ed �Zd d � Zdd� ZdS )� N)�ABCMeta�abstractmethod)� defaultdict)�datetime� timedelta�timezone)� format_tb)�EVENT_JOB_ERROR�EVENT_JOB_EXECUTED�EVENT_JOB_MISSED�JobExecutionEventc s e Zd Z� fdd�Z� ZS )�MaxInstancesReachedErrorc s t � �d|j|jf � d S )NzAJob "%s" has already reached its maximum number of instances (%d))�super�__init__�id� max_instances)�self�job�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/base.pyr s ��z!MaxInstancesReachedError.__init__)�__name__� __module__� __qualname__r � __classcell__r r r r r s r c sj e Zd ZdZdZdZe�d�Z� fdd�Z dd� Z dd d �Z d d � Z e d d� �Zdd� Zddd�Z� ZS )� BaseExecutorzRAbstract base class that defines the interface that every executor must implement.Nzapscheduler.executorsc s t � �� tdd� �| _d S )Nc S s dS )Nr r r r r r �<lambda>" � z'BaseExecutor.__init__.<locals>.<lambda>)r r r � _instances)r r r r r s zBaseExecutor.__init__c C s& || _ |�� | _t�d|� ��| _dS )av Called by the scheduler when the scheduler is being started or when the executor is being added to an already running scheduler. :param apscheduler.schedulers.base.BaseScheduler scheduler: the scheduler that is starting this executor :param str|unicode alias: alias of this executor as it was assigned to the scheduler zapscheduler.executors.N)� _schedulerZ _create_lock�_lock�logging� getLogger�_logger)r Z scheduler�aliasr r r �start$ s zBaseExecutor.startTc C s dS )z� Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr )r �waitr r r �shutdown2 s zBaseExecutor.shutdownc C sv | j dusJ d��| j �J | j|j |jkr4t|��| �||� | j|j d7 < W d � n1 sh0 Y dS )aH Submits job for execution. :param Job job: job to execute :param list[datetime] run_times: list of datetimes specifying when the job should have been run :raises MaxInstancesReachedError: if the maximum number of allowed instances for this job has been reached Nz&This executor has not been started yet� )r! r r r r �_do_submit_job�r r � run_timesr r r � submit_job: s zBaseExecutor.submit_jobc C s dS )z>Performs the actual task of scheduling `run_job` to be called.Nr r+ r r r r* M s zBaseExecutor._do_submit_jobc C sh | j �8 | j| d8 < | j| dkr0| j|= W d � n1 sD0 Y |D ]}| j�|� qRdS )z� Called by the executor with the list of generated events when :func:`run_job` has been successfully called. r) r N)r! r r Z_dispatch_event)r �job_id�events�eventr r r �_run_job_successQ s &z BaseExecutor._run_job_successc C sp | j �8 | j| d8 < | j| dkr0| j|= W d � n1 sD0 Y |j||f}| jjd||d� dS )zRCalled by the executor with the exception if there is an error calling `run_job`.r) r NzError running job %s)�exc_info)r! r r r$ �error)r r. �exc� tracebackr2 r r r �_run_job_error_ s & zBaseExecutor._run_job_error)T)N)r r r �__doc__r r! r" r# r$ r r& r( r- r r* r1 r6 r r r r r r s r )� metaclassc C s( g }t �|�}|D �]}| jdurlt�tj�| }t| jd�}||krl|�t t | j ||�� |� d| |� q|� d| |� z| j| ji | j��} W nh ty� t�� dd� \} } d�t| ��} |�t t| j ||| | d�� |�d| � t�| � ~ Y q0 |�t t| j ||| d �� |� d | � q|S ) zx Called by executors to run the job. Returns a list of scheduler events to be dispatched by the scheduler. N��seconds�%Run time of job "%s" was missed by %s�"Running job "%s" (scheduled at %s)r) � �� exceptionr5 � Job "%s" raised an exception��retval� Job "%s" executed successfully�r" r# Zmisfire_grace_timer �nowr �utcr �appendr r r �warning�info�func�args�kwargs� BaseException�sysr2 �joinr r r? r5 � clear_framesr � r Zjobstore_aliasr, Z logger_namer/ �loggerZrun_time� differenceZ grace_timerB r4 �tbZ formatted_tbr r r �run_jobj sP �� �� ��rU c � s, g }t �|�}|D �]}| jdurlt�tj�| }t| jd�}||krl|�t t | j ||�� |� d| |� q|� d| |� z | j| ji | j��I dH } W nf ty� t�� dd� \} } d�t| ��} |�t t| j ||| | d�� |�d| � t�| � Y q0 |�t t| j ||| d �� |� d | � q|S ) z Coroutine version of run_job().Nr9 r; r< r) r= r> r@ rA rC rD rQ r r r �run_coroutine_job� sN �� �� ��rV )r" rN r5 �abcr r � collectionsr r r r r Zapscheduler.eventsr r r r � Exceptionr r rU rV r r r r �<module> s Q7
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка