o _J@h@@s^ddlZddlmZmZGdddeZGdddeZGdddeZGd d d ed Z dS) N)ABCMetaabstractmethodc eZdZdZfddZZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.ctd|ddS)NzNo job by the id of z was foundsuper__init__selfZjob_id __class__M/var/www/html/venv/lib/python3.10/site-packages/apscheduler/jobstores/base.pyr zJobLookupError.__init____name__ __module__ __qualname____doc__r __classcell__rrr rrrcr)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.cr)NzJob identifier (z ) conflicts with an existing jobrr r rrr rzConflictingIdError.__init__rrrr rr rrcr)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. cr)NzJob (z`) cannot be added to this job store because a reference to the callable could not be determined.rr r rrr s zTransientJobError.__init__rrrr rrsrc@seZdZdZdZdZedZddZ ddZ dd Z e d d Z e d d Ze ddZe ddZe ddZe ddZe ddZe ddZddZdS) BaseJobStorezSAbstract base class that defines the interface that every job store must implement.Nzapscheduler.jobstorescCs"||_||_td||_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 Z scheduleraliasrrrstart's zBaseJobStore.startcCdS)z2Frees any resources still bound to this job store.Nrr rrrshutdown5zBaseJobStore.shutdowncCsNt|D] \}}|jdur$|dkr!|d|}|d|=||dSqdS)Nr) enumerateZ next_run_timeextend)r jobsijobZ paused_jobsrrr_fix_paused_jobs_sorting8s    z%BaseJobStore._fix_paused_jobs_sortingcCr")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 Nrr rrr lookup_jobAr%zBaseJobStore.lookup_jobcCr")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 nowrrr get_due_jobsMr%zBaseJobStore.get_due_jobscCr")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 Nrr#rrrget_next_run_timeWr%zBaseJobStore.get_next_run_timecCr")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] Nrr#rrr get_all_jobs`r%zBaseJobStore.get_all_jobscCr")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*rrradd_jobmr%zBaseJobStore.add_jobcCr")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 Nrr1rrr update_jobvr%zBaseJobStore.update_jobcCr")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 Nrr rrr remove_jobr%zBaseJobStore.remove_jobcCr")z!Removes all jobs from this store.Nrr#rrrremove_all_jobsr%zBaseJobStore.remove_all_jobscCsd|jjdS)N<>)r rr#rrr__repr__szBaseJobStore.__repr__)rrrrrrrrrr!r$r+rr,r.r/r0r2r3r4r5r8rrrrr s2          r) metaclass) rabcrrKeyErrorrr ValueErrorrrrrrrs