iddlmZmZddlZddlZGddeZGddeZGddeZ Gd d ej eZ dS) )ABCMetaabstractmethodNc"eZdZdZfdZxZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.c^tt|d|zdS)Nz No job by the id of %s was found)superr__init__selfjob_id __class__s `/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/apscheduler/jobstores/base.pyr zJobLookupError.__init__ s. nd##,,-PSY-YZZZZZ__name__ __module__ __qualname____doc__r __classcell__r s@rrrsGLL[[[[[[[[[rrc"eZdZdZfdZxZS)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.c^tt|d|zdS)Nz2Job identifier (%s) conflicts with an existing job)rrr r s rr zConflictingIdError.__init__s=  $''00 AF J L L L L Lrrrs@rrrsGBBLLLLLLLLLrrc"eZdZdZfdZxZS)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. c^tt|d|zdS)NzgJob (%s) cannot be added to this job store because a reference to the callable could not be determined.)rrr r s rr zTransientJobError.__init__s= &&// (*0 1 2 2 2 2 2rrrs@rrrsB 222222222rrceZdZdZdZdZejdZdZ 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|z|_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 scheduleraliass rstartzBaseJobStore.start)s.$ ()Ce)KLL rcdS)z2Frees any resources still bound to this job store.Nr s rshutdownzBaseJobStore.shutdown7rct|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_sorting:smoo  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_jobCr,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_jobsOr,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_timeYr,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_jobsbr,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 r3s radd_jobzBaseJobStore.add_jobor,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)rAs r update_jobzBaseJobStore.update_jobxr,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)r7s r remove_jobzBaseJobStore.remove_jobr,rcdS)z!Removes all jobs from this store.Nr)r*s rremove_all_jobszBaseJobStore.remove_all_jobsr,rc d|jjzS)Nz<%s>)r rr*s r__repr__zBaseJobStore.__repr__s///r)rrrrr r!r"r#r$r'r+r5rr8r;r=r?rBrDrFrHrJr)rrrr"sQ]]J Fg 788G M M MAAA   ^    ^   ^    ^    ^   ^   ^ 00^000000rr) abcrrr"sixKeyErrorrr ValueErrorrwith_metaclassrr)rrrPs '''''''' [[[[[X[[[LLLLLLLL 2 2 2 2 2 2 2 2m0m0m0m0m0%3%g..m0m0m0m0m0r