- class apscheduler.jobstores.base.BaseJobStore¶
Abstract base class that defines the interface that every job store must implement.
Adds the given job to this store.
Parameters: job (Job) – the job to add Raises ConflictingIdError: if there is another job in this store with the same ID
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.
Return type: list[Job]
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).
Parameters: now (datetime.datetime) – the current (timezone aware) datetime Return type: list[Job]
Returns the earliest run time of all the jobs stored in this job store, or None if there are no active jobs.
Return type: datetime.datetime
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.
Parameters: job_id (str|unicode) – identifier of the job Return type: Job
Removes all jobs from this store.
Removes the given job from this store.
Parameters: job_id (str|unicode) – identifier of the job Raises JobLookupError: if the job does not exist
Frees any resources still bound to this job store.
- start(scheduler, alias)¶
Called by the scheduler when the scheduler is being started or when the job store is being added to an already running scheduler.
- scheduler (apscheduler.schedulers.base.BaseScheduler) – the scheduler that is starting this job store
- alias (str|unicode) – alias of this job store as it was assigned to the scheduler
Replaces the job in the store with the given newer version.
Parameters: job (Job) – the job to update Raises JobLookupError: if the job does not exist