o th@sjddlmZmZddlZddlZGdddeZGdddeZGdddeZ Gd d d e eZ dS) )ABCMetaabstractmethodNc eZdZdZfddZZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.ctt|d|dS)Nz No job by the id of %s was found)superr__init__selfjob_id __class__P/var/www/html/bot/env/lib/python3.10/site-packages/apscheduler/jobstores/base.pyr szJobLookupError.__init____name__ __module__ __qualname____doc__r __classcell__rrr rrrcr)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.cr)Nz2Job identifier (%s) conflicts with an existing job)rrrr r rrrs zConflictingIdError.__init__rrrr rrrrcr)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. cr)NzgJob (%s) cannot be added to this job store because a reference to the callable could not be determined.)rrrr r rrrs 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.%sN) _scheduler_aliaslogging getLogger_logger)r scheduleraliasrrrstart)s zBaseJobStore.startcCdS)z2Frees any resources still bound to this job store.Nrr rrrshutdown7zBaseJobStore.shutdowncCsNt|D] \}}|jdur$|dkr!|d|}|d|=||dSqdS)Nr) enumerate next_run_timeextend)r jobsijob paused_jobsrrr_fix_paused_jobs_sorting:s    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_jobCr%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_jobsOr%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_timeYr%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_jobsbr%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_jobor%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 Nrr3rrr update_jobxr%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_jobscCs d|jjS)Nz<%s>)r rr#rrr__repr__s zBaseJobStore.__repr__)rrrrrrrrrr!r$r-rr.r0r1r2r4r5r6r7r8rrrrr"s2          r) abcrrrsixKeyErrorrr ValueErrorrwith_metaclassrrrrrs