OwgddlZddlZddlZddlmZmZddlmZddlmZm Z m Z ddlm Z ddl m Z mZmZmZGddeZGd d e Zd Zd Zy)N)ABCMetaabstractmethod) defaultdict)datetime timedeltatimezone) format_tb)EVENT_JOB_ERROREVENT_JOB_EXECUTEDEVENT_JOB_MISSEDJobExecutionEventceZdZfdZxZS)MaxInstancesReachedErrorcVt|d|j|jfzy)NzAJob "%s" has already reached its maximum number of instances (%d))super__init__id max_instances)selfjob __class__s Q/var/www/horilla/myenv/lib/python3.12/site-packages/apscheduler/executors/base.pyrz!MaxInstancesReachedError.__init__s*  Ovvs(() * )__name__ __module__ __qualname__r __classcell__rs@rrrs   rrceZdZdZdZdZejdZfdZ dZ d dZ dZ e dZd Zd d ZxZS) BaseExecutorzRAbstract base class that defines the interface that every executor must implement.Nzapscheduler.executorscDt|td|_y)Ncy)Nrr#rrz'BaseExecutor.__init__.."r)rrr _instances)rrs rrzBaseExecutor.__init__ s %i0rcv||_|j|_tjd||_y)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) _scheduler _create_lock_locklogging getLogger_logger)r scheduleraliass rstartzBaseExecutor.start$s5$++- ((+A%)IJ rcy)z Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr#)rwaits rshutdownzBaseExecutor.shutdown2r%rc4|jJd|j5|j|j|jk\r t ||j |||j|jxxdz cc<dddy#1swYyxYw)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&rrr_do_submit_jobrr run_timess r submit_jobzBaseExecutor.submit_job:szz%O'OO% ZZ )svv&#*;*;;.s33   Y / OOCFF #q ( #  ) ) )s A%BBcy)z>Performs the actual task of scheduling `run_job` to be called.Nr#r7s rr6zBaseExecutor._do_submit_jobMr%rc|j5|j|xxdzcc<|j|dk(r |j|=ddd|D]}|jj|y#1swY,xYw)z Called by the executor with the list of generated events when :func:`run_job` has been successfully called. r5rN)r*r&r(_dispatch_event)rjob_ideventsevents r_run_job_successzBaseExecutor._run_job_successQst ZZ , OOF #q ( #v&!+OOF+ ,  3E OO + +E 2 3  , ,s 7A//A8c |j5|j|xxdzcc<|j|dk(r |j|=ddd|j||f}|jj d||y#1swY7xYw)zRCalled by the executor with the exception if there is an error calling `run_job`.r5rNzError running job %s)exc_info)r*r&rr-error)rr=exc tracebackrBs r_run_job_errorzBaseExecutor._run_job_error_s{ ZZ , OOF #q ( #v&!+OOF+ , MM3 2 16HM  , ,s 7A::B)T)N)rrr__doc__r(r*r+r,r-rr0r3r9rr6r@rFrrs@rr r sY\J Eg 78G1 K )&MM 3Nrr ) metaclassc g}tj|}|D]}|jtjt j |z }t|j}||kDr?|jtt|j|||jd|||jd|| |j|ji|j } |jtt"|j||| |jd| |S#t$$rt'j(dd\} } dj+t-| } |jtt.|j||| | |j1d |t3j4| ~ YwxYw) zx Called by executors to run the job. Returns a list of scheduler events to be dispatched by the scheduler. Nseconds%Run time of job "%s" was missed by %s"Running job "%s" (scheduled at %s)retvalJob "%s" executed successfullyr5 exceptionrEJob "%s" raised an exceptionr+r,misfire_grace_timernowrutcrappendr r rwarninginfofuncargskwargsr BaseExceptionsysrBjoinr r rSrE clear_frames rjobstore_aliasr8 logger_namer>loggerrun_time difference grace_timerOrDtb formatted_tbs rrun_jobrljs F   { +F*?  ! ! -!hll3h>J"3+A+ABJJ& %(#&&.( FZX 8#xH ?SXXsxx63::6F( MM!&QW  KK8# >U*?X M5 llnQR(GC779R=1L MM!#FF"!*     ;S A  " "2 &# s>&D((BF?>F?c Kg}tj|}|D]}|jtjt j |z }t|j}||kDr?|jtt|j|||jd|||jd|| |j|ji|j d{} |jtt"|j||| |jd||S7H#t$$rt'j(dd\} } dj+t-| } |jtt.|j||| | |j1d |t3j4| YwxYww) zCoroutine version of run_job().NrJrLrMrNrPr5rQrRrTrUrcs rrun_coroutine_jobrns F   { +F&?  ! ! -!hll3h>J"3+A+ABJJ& %(#&&.( FZX 8#xH ?#388SXX<<M&?P M1= 'llnQR(GC779R=1L MM!#FF"!*     ;S A  " "2 & 's>B=G )D4)D2*D4.AG 2D44BG G  G  G )r+r`rEabcrr collectionsrrrrr apscheduler.eventsr r r r Exceptionrr rlrnr#rrrssO '#22 y NNWNNb4n,r