+ *Qj^RIHtHt^RIHt^RIHtHt^RIHt^RI t ^RI t ^RI H t ^RI t ^RIHtHtHtHt!RR ]4t!R R ] P*!]]44tR tR#) )ABCMetaabstractmethod) defaultdict)datetime timedelta) format_tbN)utc)JobExecutionEventEVENT_JOB_MISSEDEVENT_JOB_ERROREVENT_JOB_EXECUTEDc2aa]tRt^toV3RltRtVtV;t#)MaxInstancesReachedErrorch<\\V` RVPVP3,4R#)zAJob "%s" has already reached its maximum number of instances (%d)N)superr__init__id max_instances)selfjob __class__s&&s/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/apscheduler/executors/base.pyr!MaxInstancesReachedError.__init__s- &6 O VVS&& ' ( ))__name__ __module__ __qualname____firstlineno__r__static_attributes____classdictcell__ __classcell__r __classdict__s@@rrrs))rrcaa]tRt^toRtRtRt]P!R4t V3Rlt Rt R Rlt Rt ]R4tR tR R ltR tVtV;t#) BaseExecutorzRAbstract base class that defines the interface that every executor must implement.Nzapscheduler.executorscN<\\V` 4\R4VnR#)c^#)rrrrr'BaseExecutor.__init__..sarN)rr&rr _instances)rrs&rrBaseExecutor.__init__s lD*,%i0rc WnVP4Vn\P!RV,4VnR#)aF 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&&&rstartBaseExecutor.start!s1$++- (()Ce)KL rc R#)zo Shuts down this executor. :param bool wait: ``True`` to wait until all submitted jobs have been executed Nr)rwaits&&rshutdownBaseExecutor.shutdown/rc tVPfQR4hVP;_uu_4VPVP,VP8d \ V4hVP W4VPVP;;,^, uu&RRR4R# +'giR#;i)a 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)r0r+rrr_do_submit_jobrr run_timess&&&r submit_jobBaseExecutor.submit_job7s{zz%O'OO% ZZZsvv&#*;*;;.s33    / OOCFF #q ( # ZZZs A2B&& B7 c R#)z>Performs the actual task of scheduling `run_job` to be called.Nrr?s&&&rr>BaseExecutor._do_submit_jobJr<rc 6VP;_uu_4VPV;;,^,uu&VPV,^8XdVPVRRR4VFpVPPV4K R# +'giL6;i)zn Called by the executor with the list of generated events when :func:`run_job` has been successfully called. N)r0r+r._dispatch_event)rjob_ideventsevents&&& r_run_job_successBaseExecutor._run_job_successNsi ZZZ OOF #q ( #v&!+OOF+ E OO + +E 2 Zs AB B c DVP;_uu_4VPV;;,^,uu&VPV,^8XdVPVRRR4VPW#3pVPP RWR7R# +'giL=;i)zRCalled by the executor with the exception if there is an error calling `run_job`.NzError running job %s)exc_info)r0r+rr3error)rrGexc tracebackrMs&&&& r_run_job_errorBaseExecutor._run_job_error\sq ZZZ OOF #q ( #v&!+OOF+ MM32 16M Zs AB B )r+r0r3r.)T)N)rrrr__doc__r.r0r1r2r3rr6r:rArr>rJrQr r!r"r#s@@rr&r&s_\J E 78G1 M )&MM 3NNrr&c .p\P!V4pVEFpVPe}\P!\ 4V, p\ VPR7pWx8d@VP\\VPVV44VPRW4KVPRW4VP!VP/VPBp VP\\ VPWV R74VPRV4EK V# \"d\$P&!4R,wrRP)\+T 44p TP\\,TPYYR 74TP/R T4\0P2'd\$P4!4? EK^RIp T P9T 4? EKi;i) zl 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 successfully:NN) exceptionrPzJob "%s" raised an exception)r1r2misfire_grace_timernowr rappendr r rwarninginfofuncargskwargsr BaseExceptionsysrMjoinrr rYsixPY2 exc_clearrP clear_frames)rjobstore_aliasr@ logger_namerHloggerrun_time difference grace_timerVrOtb formatted_tbrPs&&&& rrun_jobrqgs F   { +F  ! ! -!c*X5J"3+A+ABJ& /0@#&&.08:;FX 8#H ?XXsxx63::6F" MM+,>39; < KK8# >CF M) llnR(GC779R=1L MM+OSVV^69S T   ;S Awww  &&r* s<&D''B-G3G32G3)abcrr collectionsrrrrPrr1rcpytzr reapscheduler.eventsr r r r Exceptionrwith_metaclassobjectr&rqrrrrysX'#(  NN)y)NN3%%gv6NNb+r