mirror
/
bazarr
mirror of https://github.com/morpheus65535/bazarr
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge branch 'development' into python3

This commit is contained in:
Louis Vézina 2019-10-31 13:55:50 -04:00
parent 7f80b1de83 f825917c9d
commit 37a23202d7
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bazarr/scheduler.py
View File

@ -16,7 +16,7 @@ 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 apscheduler.triggers.date import DateTrigger
from apscheduler.events import EVENT_JOB_SUBMITTED, EVENT_JOB_EXECUTED from apscheduler.events import EVENT_JOB_SUBMITTED, EVENT_JOB_EXECUTED, EVENT_JOB_ERROR
from datetime import datetime from datetime import datetime
import pytz import pytz
from tzlocal import get_localzone from tzlocal import get_localzone
@ -73,14 +73,18 @@ global running_tasks
running_tasks = [] running_tasks = []
def task_listener(event): def task_listener_add(event):
if event.job_id in running_tasks: if event.job_id not in running_tasks:
running_tasks.remove(event.job_id)
else:
running_tasks.append(event.job_id) running_tasks.append(event.job_id)
scheduler.add_listener(task_listener, EVENT_JOB_SUBMITTED | EVENT_JOB_EXECUTED) def task_listener_remove(event):
if event.job_id in running_tasks:
running_tasks.remove(event.job_id)
scheduler.add_listener(task_listener_add, EVENT_JOB_SUBMITTED)
scheduler.add_listener(task_listener_remove, EVENT_JOB_EXECUTED | EVENT_JOB_ERROR)
def schedule_update_job(): def schedule_update_job():