Nh@sddlmZmZddlZddlZGdddeZGdddeZGdddeZ Gd d d ej eZ dS) )ABCMetaabstractmethodNcs(eZdZdZfddZS)JobLookupErrorzBRaised when the job store cannot find a job for update or removal.cstt|jd|dS)Nz No job by the id of %s was found)superr__init__)selfjob_id) __class__V/mod/web/acousticsspace/venv/lib/python3.5/site-packages/apscheduler/jobstores/base.pyr szJobLookupError.__init__)__name__ __module__ __qualname____doc__rr r )r r rs rcs(eZdZdZfddZS)ConflictingIdErrorz8Raised when the uniqueness of job IDs is being violated.cstt|jd|dS)Nz2Job identifier (%s) conflicts with an existing job)rrr)rr)r r r rszConflictingIdError.__init__)r r rrrr r )r r rs rcs(eZdZdZfddZS)TransientJobErrorzs Raised when an attempt to add transient (with no func_ref) job to a persistent job store is detected. cstt|jd|dS)NzgJob (%s) cannot be added to this job store because a reference to the callable could not be determined.)rrr)rr)r r r rszTransientJobError.__init__)r r rrrr r )r r rs rc@seZdZdZdZdZejdZddZ 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,||_||_tjd||_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.shutdowncCsgx`t|D]R\}}|jdk r |dkr^|d|}|d|=|j|Pq WdS)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 )rrr 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 )rrr 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 )rrr 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 )rrr r r remove_jobszBaseJobStore.remove_jobcCsdS)z!Removes all jobs from this store.Nr )rr r r remove_all_jobsszBaseJobStore.remove_all_jobscCsd|jjS)Nz<%s>)r r )rr r r __repr__szBaseJobStore.__repr__)r r rrrrrrrrrr rr!r#r$r%r&r'r(r)r*r r r r r"s           r) abcrrrsixKeyErrorrr ValueErrorrwith_metaclassrr r r r s