i@pSSKrSSKJrJr "SS\5r"SS\5r"SS\5r"S S \S 9r g) N)ABCMetaabstractmethodc,^\rSrSrSrU4SjrSrU=r$)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.c,>[TU]SUS35 g)NzNo job by the id of z was foundsuper__init__selfjob_id __class__s G/app/mltbenv/lib/python3.13/site-packages/apscheduler/jobstores/base.pyr JobLookupError.__init__s /xzBC__name__ __module__ __qualname____firstlineno____doc__r __static_attributes__ __classcell__rs@rrrsLDDrrc,^\rSrSrSrU4SjrSrU=r$)ConflictingIdError z8Raised when the uniqueness of job IDs is being violated.c,>[TU]SUS35 g)NzJob identifier (z ) conflicts with an existing jobr r s rr ConflictingIdError.__init__s +F83STUrrrrs@rrr sBVVrrc,^\rSrSrSrU4SjrSrU=r$)TransientJobErrorzg Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. c,>[TU]SUS35 g)NzJob (z`) cannot be added to this job store because a reference to the callable could not be determined.r r s rr TransientJobError.__init__s! F8' ' rrrrs@rr#r#s   rr#c\rSrSrSrSrSr\R"S5r Sr Sr Sr \ S5r\ S 5r\ S 5r\ S 5r\ S 5r\ S 5r\ S5r\ S5rSrSrg) BaseJobStore zSAbstract base class that defines the interface that every job store must implement.Nzapscheduler.jobstorescXXlX l[R"SU35Ulg)aH Called by the scheduler when the scheduler is being started or when the job store is being added to an already running scheduler. :param apscheduler.schedulers.base.BaseScheduler scheduler: the scheduler that is starting this job store :param str|unicode alias: alias of this job store as it was assigned to the scheduler zapscheduler.jobstores.N) _scheduler_aliaslogging getLogger_logger)r scheduleraliass rstartBaseJobStore.start's($ ((+A%)IJ rcg)z2Frees any resources still bound to this job store.Nrr s rshutdownBaseJobStore.shutdown5rc[U5H5up#URcMUS:aUSUnUSU2 URU5 g g)Nr) enumerate next_run_timeextend)r jobsijob paused_jobss r_fix_paused_jobs_sorting%BaseJobStore._fix_paused_jobs_sorting8sJoFA  ,q5"&r(KRaRKK , &rcg)a Returns a specific job, or ``None`` if it isn't found.. The job store is responsible for setting the ``scheduler`` and ``jobstore`` attributes of the returned job to point to the scheduler and itself, respectively. :param str|unicode job_id: identifier of the job :rtype: Job Nrr rs r lookup_jobBaseJobStore.lookup_jobAr8rcg)z Returns the list of jobs that have ``next_run_time`` earlier or equal to ``now``. The returned jobs must be sorted by next run time (ascending). :param datetime.datetime now: the current (timezone aware) datetime :rtype: list[Job] Nr)r nows r get_due_jobsBaseJobStore.get_due_jobsMr8rcg)z Returns the earliest run time of all the jobs stored in this job store, or ``None`` if there are no active jobs. :rtype: datetime.datetime Nrr5s rget_next_run_timeBaseJobStore.get_next_run_timeWr8rcg)a_ Returns a list of all jobs in this job store. The returned jobs should be sorted by next run time (ascending). Paused jobs (next_run_time == None) should be sorted last. The job store is responsible for setting the ``scheduler`` and ``jobstore`` attributes of the returned jobs to point to the scheduler and itself, respectively. :rtype: list[Job] Nrr5s r get_all_jobsBaseJobStore.get_all_jobs`r8rcg)z Adds the given job to this store. :param Job job: the job to add :raises ConflictingIdError: if there is another job in this store with the same ID Nrr r?s radd_jobBaseJobStore.add_jobmr8rcg)z Replaces the job in the store with the given newer version. :param Job job: the job to update :raises JobLookupError: if the job does not exist NrrRs r update_jobBaseJobStore.update_jobvr8rcg)z Removes the given job from this store. :param str|unicode job_id: identifier of the job :raises JobLookupError: if the job does not exist NrrDs r remove_jobBaseJobStore.remove_jobr8rcg)z!Removes all jobs from this store.Nrr5s rremove_all_jobsBaseJobStore.remove_all_jobsr8rc6SURRS3$)N<>)rrr5s r__repr__BaseJobStore.__repr__s4>>**+1--r)r,r/r+)rrrrrr+r,r-r.r/r2r6rArrErIrLrOrSrVrYr\rarrrrr(r( s]J F 78G KA                  00.rr() metaclass) r-abcrrKeyErrorrr ValueErrorr#r(rrrrgsA'DXDVV   m.Wm.r