From 4ebf0ddb7fed33150a7d65375aae97c0a020ac4b Mon Sep 17 00:00:00 2001 From: Johannes Findeisen Date: Sun, 8 Dec 2013 19:33:59 +0100 Subject: [PATCH] just added Linspector as prefix to job and scheduler --- bin/linspector | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/bin/linspector b/bin/linspector index ca474de..d915f7a 100755 --- a/bin/linspector +++ b/bin/linspector @@ -34,8 +34,8 @@ from multiprocessing import Pool from linspector.config.parser import FullConfigParser from linspector.core.interface import LinspectorInterface -from linspector.core.job import Job -from linspector.core.scheduler import Scheduler +from linspector.core.job import LinspectorJob +from linspector.core.scheduler import LinspectorScheduler from linspector.frontends.lish import LishFrontend from linspector.tasks.task import TaskExecutor @@ -122,7 +122,7 @@ def main(): logger.error(msg) exit() - scheduler = Scheduler({"apscheduler.threadpool.core_threads": args.corethreads, + scheduler = LinspectorScheduler({"apscheduler.threadpool.core_threads": args.corethreads, "apscheduler.threadpool.max_threads": args.threads}) scheduler.start() TaskExecutor.Instance() @@ -154,11 +154,11 @@ def main(): time_delta += float(args.delay) new_start_date = start_date + datetime.timedelta(seconds=time_delta) - job = Job(service, - host, - hostgroup.get_members(), - core, - hostgroup) + job = LinspectorJob(service, + host, + hostgroup.get_members(), + core, + hostgroup) scheduler_job = period.createJob(scheduler, job, handle_job, start_date=new_start_date) if scheduler_job is not None: job.set_job(scheduler_job)