iddlZddlZddlZddlmZmZddlmZddlmZm 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)MaxInstancesReachedErrorcZt|d|jd|jdy)NzJob "z7" has already reached its maximum number of instances ())super__init__id max_instances)selfjob __class__s ]/var/www/pod-logistic/pod-api/venv/lib/python3.12/site-packages/apscheduler/executors/base.pyrz!MaxInstancesReachedError.__init__s3 CFF8!!"! % )__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$r8s rr7zBaseExecutor._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. r6rN)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`.r6rNzError running job %s)exc_info)r+r'rr.error)rr>exc tracebackrCs 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.rr1r4r:rr7rArGrrs@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 successfullyr6 exceptionrFJob "%s" raised an exceptionr,r-misfire_grace_timernowrutcrappendr r rwarninginfofuncargskwargsr BaseExceptionsysrCjoinr r rTrF clear_frames rjobstore_aliasr9 logger_namer?loggerrun_time difference grace_timerPrEtb formatted_tbs rrun_jobrmjs 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().NrKrMrNrOrQr6rRrSrUrVrds rrun_coroutine_jobros 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,rarFabcrr collectionsrrrrr apscheduler.eventsr r r r Exceptionrr!rmror$rrrtsO '#22 y NNWNNb4n,r