o Tj@sddlZddlZddlZddlmZmZddlmZddlmZm Z m Z ddlm Z ddl m Z mZmZmZGdddeZGd d d ed Zd d ZddZdS)N)ABCMetaabstractmethod) defaultdict)datetime timedeltatimezone) format_tb)EVENT_JOB_ERROREVENT_JOB_EXECUTEDEVENT_JOB_MISSEDJobExecutionEventcseZdZfddZZS)MaxInstancesReachedErrorcs"td|jd|jddS)NzJob "z7" has already reached its maximum number of instances ())super__init__id max_instances)selfjob __class__]/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/apscheduler/executors/base.pyrs  z!MaxInstancesReachedError.__init__)__name__ __module__ __qualname__r __classcell__rrrrr sr csjeZdZdZdZdZedZfddZ ddZ dd d Z d d Z e d dZddZdddZZS) BaseExecutorzRAbstract base class that defines the interface that every executor must implement.Nzapscheduler.executorscsttdd|_dS)NcSdS)Nrrrrrr"z'BaseExecutor.__init__..)rrr _instances)rrrrr s zBaseExecutor.__init__cCs&||_||_td||_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) _scheduler _create_lock_locklogging getLogger_logger)r scheduleraliasrrrstart$s zBaseExecutor.startTcCr)z Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr)rwaitrrrshutdown2r zBaseExecutor.shutdowncCsx|jdus Jd|j&|j|j|jkrt|||||j|jd7<WddS1s5wYdS)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_timesrrr submit_job:s  "zBaseExecutor.submit_jobcCr)z>Performs the actual task of scheduling `run_job` to be called.Nrr/rrrr.Mr zBaseExecutor._do_submit_jobcCsh|j|j|d8<|j|dkr|j|=Wdn1s"wY|D]}|j|q)dS)z Called by the executor with the list of generated events when :func:`run_job` has been successfully called. r-rN)r$r!r"_dispatch_event)rjob_ideventseventrrr_run_job_successQszBaseExecutor._run_job_successcCsp|j|j|d8<|j|dkr|j|=Wdn1s"wY|j||f}|jjd||ddS)zRCalled by the executor with the exception if there is an error calling `run_job`.r-rNzError running job %s)exc_info)r$r!rr'error)rr3exc tracebackr7rrr_run_job_error_s zBaseExecutor._run_job_error)T)N)rrr__doc__r"r$r%r&r'rr*r,r1rr.r6r;rrrrrrs    r) metaclassc Cs&g}t|}|D]}|jdur5ttj|}t|jd}||kr5|t t |j ||| d||q | d||z |j|ji|j} Wn4ty|tdd\} } dt| } |t t|j ||| | d|d|t| ~ Yq w|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. Nseconds%Run time of job "%s" was missed by %s"Running job "%s" (scheduled at %s)r- exceptionr:Job "%s" raised an exceptionretvalJob "%s" executed successfullyr%r&misfire_grace_timernowrutcrappendr r rwarninginfofuncargskwargs BaseExceptionsysr7joinrr rDr: clear_framesr rjobstore_aliasr0 logger_namer4loggerrun_time difference grace_timerGr9tb formatted_tbrrrrun_jobjsR       r`c s,g}t|}|D]}|jdur6ttj|}t|jd}||kr6|t t |j ||| d||q | d||z|j|ji|jIdH} Wn3tytdd\} } dt| } |t t|j ||| | d|d|t| Yq w|t t|j ||| d | d |q |S) zCoroutine version of run_job().Nr>r@rAr-rBrCrErFrHrIrWrrrrun_coroutine_jobsR       ra)r%rTr:abcrr collectionsrrrrrapscheduler.eventsr r r r Exceptionr rr`rarrrrs  Q 7