如何从调度程序中获取丢失的作业

Question

我正在使用BackgroundScheduler调度程序来调度我的作业。

from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore

jobstores = {'default': SQLAlchemyJobStore(engine=my_db_engine)}
scheduler = BackgroundScheduler(jobstores=jobstores)

job = scheduler.add_job(my_job, run_date=some_future_time, misfire_grace_time=60)

我想为通过misfire_grace_time的调度程序获取丢失的作业。scheduler.get_jobs()只会提供未来的工作机会。

Answer 1

不知道你到底想要什么，但是你可以为你错过的工作添加一个监听器：

def listener(event):
    ...

scheduler.add_listener(listener, EVENT_JOB_MISSED)

一些文档这里。