Python APSCheduler 在删除作业后抛出异常

Question

我正在 Redis 中添加作业，作业完成后我添加了一个事件处理程序。在 eventhandler 中，我返回的值基于我从 jobstore 中删除作业 id。它已成功删除，但立即抛出异常。

代码

from datetime import datetime
from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.events import EVENT_JOB_EXECUTED
import logging
logging.basicConfig()

scheduler = BackgroundScheduler()
scheduler.add_jobstore('redis')
scheduler.start()

def tick():
    print('Tick! The time is: %s' % datetime.now())
    return 'success'

def removing_jobs(event):
    if event.retval == 'success':
        scheduler.remove_job(event.job_id)

scheduler.add_listener(removing_jobs, EVENT_JOB_EXECUTED)

try:
    count = 0 
    while True:
        count += 1
        time.sleep(10)
        job_ret = scheduler.add_job(tick, 'interval', id = str(count), seconds=10)
except (KeyboardInterrupt, SystemExit):
    scheduler.shutdown()

异常

Exception in thread APScheduler:
Traceback (most recent call last):
  File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.5/threading.py", line 862, in run
    self._target(*self._args, **self._kwargs)
  File "/.virtualenvs/py3/lib/python3.5/site-packages/apscheduler/schedulers/blocking.py", line 30, in _main_loop
    wait_seconds = self._process_jobs()
  File "/.virtualenvs/py3/lib/python3.5/site-packages/apscheduler/schedulers/base.py", line 995, in _process_jobs
    jobstore.update_job(job)
  File "/.virtualenvs/py3/lib/python3.5/site-packages/apscheduler/jobstores/redis.py", line 91, in update_job
    raise JobLookupError(job.id)
apscheduler.jobstores.base.JobLookupError: 'No job by the id of 1 was found'

Answer 1

简而言之：您正在删除正在处理的作业；所以你应该在执行之外删除作业。

那是因为调度程序不知道作业的执行会做什么；所以它启动 tick 并发送一个 job 对象到 redis jobstore 以为它会再次执行。在此之前，EVENT_JOB_LISTENER 启动 removing_jobs。

问题是，当 redis' jobstore 获得更新其状态的作业时，它已经被删除，因此它引发了 JobLookupError.

Python APSCheduler 在删除作业后抛出异常

Python APSCheduler throwing exception after removing job

python

apscheduler