1
0
Fork 0
mirror of https://github.com/morpheus65535/bazarr synced 2025-03-04 02:18:12 +00:00

Another fix for #317

This commit is contained in:
Halali 2019-02-23 21:41:42 +01:00
parent d6a383dc9f
commit 8321b1575f
2 changed files with 11 additions and 4 deletions

View file

@ -877,8 +877,8 @@ def scan_disk_movie(no):
def search_missing_subtitles(no): def search_missing_subtitles(no):
authorize() authorize()
ref = request.environ['HTTP_REFERER'] ref = request.environ['HTTP_REFERER']
scheduler.add_job(series_download_subtitles, args=[no], next_run_time=datetime.now()) add_job(series_download_subtitles, args=[no], name=('search_missing_subtitles_' + str(no)))
redirect(ref) redirect(ref)
@ -889,7 +889,7 @@ def search_missing_subtitles_movie(no):
authorize() authorize()
ref = request.environ['HTTP_REFERER'] ref = request.environ['HTTP_REFERER']
scheduler.add_job(movies_download_subtitles, args=[no], next_run_time=datetime.now()) add_job(movies_download_subtitles, args=[no], name=('movies_download_subtitles_' + str(no)))
redirect(ref) redirect(ref)
@ -1066,7 +1066,7 @@ def wanted_search_missing_subtitles_list():
authorize() authorize()
ref = request.environ['HTTP_REFERER'] ref = request.environ['HTTP_REFERER']
scheduler.add_job(wanted_search_missing_subtitles, next_run_time=datetime.now()) add_job(wanted_search_missing_subtitles, name='manual_wanted_search_missing_subtitles')
redirect(ref) redirect(ref)

View file

@ -14,6 +14,7 @@ else:
from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.schedulers.background import BackgroundScheduler
from apscheduler.triggers.interval import IntervalTrigger from apscheduler.triggers.interval import IntervalTrigger
from apscheduler.triggers.cron import CronTrigger from apscheduler.triggers.cron import CronTrigger
from apscheduler.triggers.date import DateTrigger
from datetime import datetime from datetime import datetime
import pytz import pytz
from tzlocal import get_localzone from tzlocal import get_localzone
@ -98,5 +99,11 @@ radarr_full_update()
scheduler.start() scheduler.start()
def add_job(job, name=None, max_instances=1, coalesce=True, args=None):
scheduler.add_job(job, DateTrigger(run_date=datetime.now()), name=name, id=name, max_instances=max_instances,
coalesce=coalesce, args=args)
def shutdown_scheduler(): def shutdown_scheduler():
scheduler.shutdown(wait=True) scheduler.shutdown(wait=True)