This commit is contained in:
Johannes Findeisen 2014-04-19 01:51:33 +02:00
commit 098796b7ab

View file

@ -117,7 +117,7 @@ def main():
exit() exit()
scheduler = LinspectorScheduler({"apscheduler.threadpool.core_threads": args.corethreads, scheduler = LinspectorScheduler({"apscheduler.threadpool.core_threads": args.corethreads,
"apscheduler.threadpool.max_threads": args.threads}) "apscheduler.threadpool.max_threads": args.threads})
TaskExecutor.Instance() TaskExecutor.Instance()
@ -152,6 +152,7 @@ def main():
hostgroup.get_members(), hostgroup.get_members(),
core, core,
hostgroup) hostgroup)
scheduler_job = period.createJob(scheduler, job, handle_job, start_date=new_start_date) scheduler_job = period.createJob(scheduler, job, handle_job, start_date=new_start_date)
scheduler_job.misfire_grace_time = 2 scheduler_job.misfire_grace_time = 2
if scheduler_job is not None: if scheduler_job is not None: