U nj@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__>/tmp/pip-unpacked-wheel-giblih11/apscheduler/executors/base.pyrsz!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)NcSsdS)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) _schedulerZ _create_lock_locklogging getLogger_logger)rZ scheduleraliasrrrstart$s  zBaseExecutor.startTcCsdS)z Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr)rwaitrrrshutdown2szBaseExecutor.shutdownc Csb|jdk std|j@|j|j|jkr4t|||||j|jd7<W5QRXdS)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"AssertionErrorr rrr _do_submit_jobrr run_timesrrr submit_job:s  zBaseExecutor.submit_jobcCsdS)z>Performs the actual task of scheduling `run_job` to be called.Nrr-rrrr,MszBaseExecutor._do_submit_jobc CsT|j.|j|d8<|j|dkr0|j|=W5QRX|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!Z_dispatch_event)rjob_ideventseventrrr_run_job_successQs zBaseExecutor._run_job_successc Cs\|j.|j|d8<|j|dkr0|j|=W5QRX|j||f}|jjd||ddS)zRCalled by the executor with the exception if there is an error calling `run_job`.r*rzError running job %s)exc_infoN)r"r rr%error)rr0exc tracebackr4rrr_run_job_error_s  zBaseExecutor._run_job_error)T)N)rrr__doc__r!r"r#r$r%rr'r)r/rr,r3r8rrrrrrs    r) metaclassc Cs&g}t|}|D] }|jdk rlttj|}t|jd}||krl|t t |j ||| d||q| d||z|j|j|j} Wnjtk rtdd\} } dt| } |t t|j ||| | d|d|t| ~ YqX|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* exceptionr7Job "%s" raised an exceptionretvalJob "%s" executed successfullyr#r$Zmisfire_grace_timernowrutcrappendr r rwarninginfofuncargskwargs BaseExceptionsysr4joinrr rAr7 clear_framesr rZjobstore_aliasr.Z logger_namer1loggerZrun_time differenceZ grace_timerDr6tbZ formatted_tbrrrrun_jobjs^      rWc s*g}t|}|D]}|jdk rlttj|}t|jd}||krl|t t |j ||| d||q| d||z|j|j|jIdH} Wnhtk rtdd\} } dt| } |t t|j ||| | d|d|t| YqX|t t|j ||| d | d |q|S) zCoroutine version of run_job().Nr;r=r>r*r?r@rBrCrErFrSrrrrun_coroutine_jobs\     rX)r#rPr7abcrr collectionsrrrrrZapscheduler.eventsr r r r Exceptionr rrWrXrrrrs  Q7