a d@sjddlmZmZddlZddlZGdddeZGdddeZGdddeZ Gd d d e eZ dS) )ABCMetaabstractmethodNcs eZdZdZfddZZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.cstt|d|dS)Nz No job by the id of %s was found)superr__init__selfZjob_id __class__V/var/www/html/django/DPS/env/lib/python3.9/site-packages/apscheduler/jobstores/base.pyr szJobLookupError.__init____name__ __module__ __qualname____doc__r __classcell__r r r r rsrcs eZdZdZfddZZS)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.cstt|d|dS)Nz2Job identifier (%s) conflicts with an existing job)rrrrr r r rs zConflictingIdError.__init__r r r r r rsrcs eZdZdZfddZZS)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. cstt|d|dS)NzgJob (%s) cannot be added to this job store because a reference to the callable could not be determined.)rrrrr r r rs  zTransientJobError.__init__r r r r r rsrc@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)rZ scheduleraliasr r r start)s zBaseJobStore.startcCsdS)z2Frees any resources still bound to this job store.Nr rr r r shutdown7szBaseJobStore.shutdowncCsLt|D]>\}}|jdur|dkrB|d|}|d|=||qHqdS)Nr) enumerateZ next_run_timeextend)rjobsijobZ paused_jobsr r r _fix_paused_jobs_sorting:s    z%BaseJobStore._fix_paused_jobs_sortingcCsdS)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 rr r r lookup_jobCszBaseJobStore.lookup_jobcCsdS)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 )rnowr r r get_due_jobsOszBaseJobStore.get_due_jobscCsdS)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 rr r r get_next_run_timeYszBaseJobStore.get_next_run_timecCsdS)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 rr r r get_all_jobsbszBaseJobStore.get_all_jobscCsdS)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 rr#r r r add_joboszBaseJobStore.add_jobcCsdS)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 r*r r r update_jobxszBaseJobStore.update_jobcCsdS)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 rr r r remove_jobszBaseJobStore.remove_jobcCsdS)z!Removes all jobs from this store.Nr rr r r remove_all_jobsszBaseJobStore.remove_all_jobscCs d|jjS)Nz<%s>)r rrr r r __repr__szBaseJobStore.__repr__)rrrrrrrrrrrr$rr%r'r(r)r+r,r-r.r/r r r r r"s0          r) abcrrrsixKeyErrorrr ValueErrorrwith_metaclassrr r r r s