i@ddlZddlmZmZGddeZGddeZGddeZGd d e Z dS) N)ABCMetaabstractmethodc"eZdZdZfdZxZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.cRtd|ddS)NzNo job by the id of z was foundsuper__init__selfjob_id __class__s a/home/ubuntu/.hermes/hermes-agent/venv/lib/python3.11/site-packages/apscheduler/jobstores/base.pyr zJobLookupError.__init__s- BBBBCCCCC__name__ __module__ __qualname____doc__r __classcell__rs@rrrsGLLDDDDDDDDDrrc"eZdZdZfdZxZS)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.cRtd|ddS)NzJob identifier (z ) conflicts with an existing jobrr s rr zConflictingIdError.__init__s- TFTTTUUUUUrrrs@rrr sGBBVVVVVVVVVrrc"eZdZdZfdZxZS)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. cRtd|ddS)NzJob (z`) cannot be added to this job store because a reference to the callable could not be determined.rr s rr zTransientJobError.__init__s?  'F ' ' '     rrrs@rrrsB          rrceZdZdZdZdZejdZdZ dZ dZ e dZ e dZe d Ze d Ze d Ze d Ze d Ze dZdZdS) BaseJobStorezSAbstract base class that defines the interface that every job store must implement.Nzapscheduler.jobstorescZ||_||_tjd||_dS)ax 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 rstartzBaseJobStore.start's1$ ()I%)I)IJJ rcdS)z2Frees any resources still bound to this job store.Nr s rshutdownzBaseJobStore.shutdown5rct|D]9\}}|j-|dkr$|d|}|d|=||dS:dS)Nr) enumerate next_run_timeextend)r jobsijob paused_jobss r_fix_paused_jobs_sortingz%BaseJobStore._fix_paused_jobs_sorting8smoo  FAs ,q55"&rr(KRaRKK ,,, -  rcdS)aG 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 Nr*r r s r lookup_jobzBaseJobStore.lookup_jobAr-rcdS)a 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_jobszBaseJobStore.get_due_jobsMr-rcdS)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 Nr*r+s rget_next_run_timezBaseJobStore.get_next_run_timeWr-rcdS)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] Nr*r+s r get_all_jobszBaseJobStore.get_all_jobs`r-rcdS)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 Nr*r r4s radd_jobzBaseJobStore.add_jobmr-rcdS)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 Nr*rBs r update_jobzBaseJobStore.update_jobvr-rcdS)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 Nr*r8s r remove_jobzBaseJobStore.remove_jobr-rcdS)z!Removes all jobs from this store.Nr*r+s rremove_all_jobszBaseJobStore.remove_all_jobsr-rc"d|jjdS)N<>)rrr+s r__repr__zBaseJobStore.__repr__s-4>*----r)rrrrr!r"r#r$r%r(r,r6rr9r<r>r@rCrErGrIrMr*rrrr sQ]]J Fg 788G K K KAAA   ^    ^   ^    ^    ^   ^   ^ 00^0.....rr) metaclass) r#abcrrKeyErrorrr ValueErrorrrr*rrrRs''''''''DDDDDXDDDVVVVVVVV         m.m.m.m.m.Wm.m.m.m.m.m.r