我正在使用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()
只会提供未来的工作机会。
发布于 2018-06-14 09:31:42
不知道你到底想要什么,但是你可以为你错过的工作添加一个监听器:
def listener(event):
...
scheduler.add_listener(listener, EVENT_JOB_MISSED)
一些文档这里。
https://stackoverflow.com/questions/50837288
复制