dfddlmZmZddlmZddlmZmZddlmZddl Z ddl Z ddl m Z ddl Z ddlmZmZmZmZGdd eZGd d e j*eeZd Zy) )ABCMetaabstractmethod) defaultdict)datetime timedelta) format_tbN)utc)JobExecutionEventEVENT_JOB_MISSEDEVENT_JOB_ERROREVENT_JOB_EXECUTEDceZdZfdZxZS)MaxInstancesReachedErrorc^tt| d|j|jfzy)NzAJob "%s" has already reached its maximum number of instances (%d))superr__init__id max_instances)selfjob __class__s S/home/api-vastappli/venv/lib/python3.12/site-packages/apscheduler/executors/base.pyrz!MaxInstancesReachedError.__init__s- &6 O VVS&& ' ( ))__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.executorscLtt| td|_y)Ncy)Nrr#rrz'BaseExecutor.__init__..r)rr rr _instances)rrs rrzBaseExecutor.__init__s lD*,%i0rcv||_|j|_tjd|z|_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.%sN) _scheduler _create_lock_locklogging getLogger_logger)r scheduleraliass rstartzBaseExecutor.start!s3$++- (()Ce)KL rcy)z Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr#)rwaits rshutdownzBaseExecutor.shutdown/r%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_job7szz%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_jobJr%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_successNst 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 M )&MM 3Nrr c g}tj|}|D]}|jvtjt |z }t |j}||kDr?|jtt|j|||jd|||jd|| |j|ji|j} |jtt |j||| |jd||S#t"$rt%j&dd\} } dj)t+| } |jtt,|j||| | |j/d |t0j2rt%j4~ nd dl} | j9| ~ YwxYw) zx Called by executors to run the job. Returns a list of scheduler events to be dispatched by the scheduler. N)secondsz%Run time of job "%s" was missed by %sz"Running job "%s" (scheduled at %s))retvalzJob "%s" executed successfullyr5) exceptionrEzJob "%s" raised an exceptionr)r+r,misfire_grace_timernowr rappendr r rwarninginfofuncargskwargsr BaseExceptionsysrBjoinrr rLsixPY2 exc_clearrE clear_frames)rjobstore_aliasr8 logger_namer>loggerrun_time difference grace_timerJrDtb formatted_tbrEs rrun_jobrdgs F   { +F!?  ! ! -!c*X5J"3+A+ABJJ& /0@#&&.08:;FZX 8#xH ?SXXsxx63::6F" MM+,>X`39; < KK8# >C!?F M) llnQR(GC779R=1L MM+OSVV^U]69\S T   ;S Aww  &&r* s3&DB9GG)abcrr collectionsrrrrErr+rVpytzr rXapscheduler.eventsr r r r Exceptionrwith_metaclassobjectr rdr#rrrls['#(  NN)y)NN%3%%gv6NNb+r