o Tj@@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__selfjob_id __class__]/home/dinkstrade/pdmp-scanner/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 scheduleraliasrrrstart's zBaseJobStore.startcCdS)z2Frees any resources still bound to this job store.Nrr rrrshutdown5zBaseJobStore.shutdowncCsNt|D] \}}|jdur$|dkr!|d|}|d|=||dSqdS)Nr) enumerate next_run_timeextend)r jobsijob 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 Nrr5rrr 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<>)rrr%rrr__repr__szBaseJobStore.__repr__)rrrrrrrrr r#r&r/rr0r2r3r4r6r7r8r9r<rrrrr s2          r) metaclass) rabcrrKeyErrorrr ValueErrorrrrrrrs