首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >re_schedule()抛出id未找到错误

re_schedule()抛出id未找到错误
EN

Stack Overflow用户
提问于 2019-06-07 22:55:09
回答 1查看 755关注 0票数 0

我正在尝试构建一个调度程序,其中的一个用例是检查作业依赖关系,并将依赖作业的执行延迟一个增量,比如20分钟。

下面是我的示例:

代码语言:javascript
复制
from apscheduler.schedulers.blocking import BlockingScheduler
import datetime
import logging

sched = BlockingScheduler()

log_file_path="path\to\log\file"


@sched.scheduled_job('cron', day_of_week='mon-fri', hour=19, minute=53)
def scheduled_job():

     sched.add_job(run_job, id='demo_reschedule')

     logging.info("Schdeuled job at {}".format(datetime.datetime.now()))



def run_job():
     now = datetime.datetime.now()
     now_plus_20 = now + datetime.timedelta(minutes = 20)
     sched.reschedule_job('demo_reschedule',trigger='date',run_date=now_plus_20)
     logging.info("Rescheduled Job demo_reschedule to new time {}".format(now_plus_20))



if __name__ == "__main__":

    logging.basicConfig(filename=log_file_path,
                            filemode='a',
                            format=('[%(asctime)s] %(levelname)-8s %(name)-12s %(message)s'),
                            datefmt='%H:%M:%S',
                            level=logging.INFO)

    logging.info("Starting scheduler")
    sched.start()

成功添加了run_job方法,但当它执行时,我收到以下错误,

代码语言:javascript
复制
[19:51:14] INFO     root         Starting scheduler
[19:51:14] INFO     apscheduler.scheduler Added job "scheduled_job" to job store "default"
[19:51:14] INFO     apscheduler.scheduler Scheduler started
[19:53:00] INFO     apscheduler.executors.default Running job "scheduled_job (trigger: cron[day_of_week='mon-fri', hour='19', minute='53'], next run at: 2019-06-07 19:53:00 IST)" (scheduled at 2019-06-07 19:53:00+05:30)
[19:53:00] INFO     apscheduler.scheduler Added job "run_job" to job store "default"
[19:53:00] INFO     root         Schdeuled job at 2019-06-07 19:53:00.024887
[19:53:00] INFO     apscheduler.executors.default Job "scheduled_job (trigger: cron[day_of_week='mon-fri', hour='19', minute='53'], next run at: 2019-06-10 19:53:00 IST)" executed successfully
[19:53:00] INFO     apscheduler.executors.default Running job "run_job (trigger: date[2019-06-07 19:53:00 IST], next run at: 2019-06-07 19:53:00 IST)" (scheduled at 2019-06-07 19:53:00.023890+05:30)
[19:53:00] INFO     apscheduler.scheduler Removed job demo_reschedule
[19:53:00] ERROR    apscheduler.executors.default Job "run_job (trigger: date[2019-06-07 19:53:00 IST], next run at: 2019-06-07 19:53:00 IST)" raised an exception
Traceback (most recent call last):
  File "C:\ProgramData\Anaconda3\lib\site-packages\apscheduler\executors\base.py", line 125, in run_job
    retval = job.func(*job.args, **job.kwargs)
  File "path/to/demo_reschedule.py", line 33, in run_job
    sched.reschedule_job('demo_reschedule',jobstore=None,trigger='date',run_date=now_plus_20)
  File "C:\ProgramData\Anaconda3\lib\site-packages\apscheduler\schedulers\base.py", line 511, in reschedule_job
    return self.modify_job(job_id, jobstore, trigger=trigger, next_run_time=next_run_time)
  File "C:\ProgramData\Anaconda3\lib\site-packages\apscheduler\schedulers\base.py", line 483, in modify_job
    job, jobstore = self._lookup_job(job_id, jobstore)
  File "C:\ProgramData\Anaconda3\lib\site-packages\apscheduler\schedulers\base.py", line 816, in _lookup_job
    raise JobLookupError(job_id)
apscheduler.jobstores.base.JobLookupError: 'No job by the id of demo_reschedule was found'

根据我的观察,在执行作业后,它会立即从作业存储中删除,可能是因为它无法找到该作业id,但我不确定。

关于如何缓解这个问题,敬请指教。

感谢您的帮助:)

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-06-10 00:34:41

当调度程序提交发现某个调度程序已运行其进程时,它将删除该作业。这就是这里发生的事情-作业已经提交给executor,但它不再存在于作业存储中,因为它的触发器已经用完了。请尝试添加新作业。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/56496699

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档