|
|
@ -56,7 +56,7 @@ async def add_task(task_args):
|
|
|
|
trigger = IntervalTrigger(seconds=interval)
|
|
|
|
trigger = IntervalTrigger(seconds=interval)
|
|
|
|
scheduler.add_job(task_handler, trigger, args=[task_args],
|
|
|
|
scheduler.add_job(task_handler, trigger, args=[task_args],
|
|
|
|
id=task_name, replace_existing=True,
|
|
|
|
id=task_name, replace_existing=True,
|
|
|
|
max_instances=3)
|
|
|
|
max_instances=3, misfire_grace_time=10)
|
|
|
|
|
|
|
|
|
|
|
|
async def list_task():
|
|
|
|
async def list_task():
|
|
|
|
jobs = scheduler.get_jobs()
|
|
|
|
jobs = scheduler.get_jobs()
|
|
|
|