fix bug: set scheduler max_instances=3

master
wlt233 2 weeks ago
parent a5f06fc08c
commit 9ca8a35640

@ -54,7 +54,9 @@ async def add_task(task_args):
if scheduler.get_job(task_name):
scheduler.remove_job(task_name)
trigger = IntervalTrigger(seconds=interval)
scheduler.add_job(task_handler, trigger, args=[task_args], id=task_name, replace_existing=True)
scheduler.add_job(task_handler, trigger, args=[task_args],
id=task_name, replace_existing=True,
max_instances=3)
async def list_task():
jobs = scheduler.get_jobs()

Loading…
Cancel
Save