linspector/linspector-old
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

just added Linspector as prefix to job and scheduler

Browse source
This commit is contained in:
Johannes Findeisen 2013-12-08 19:33:59 +01:00
commit 4ebf0ddb7f
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
bin/linspector
View file

@ -34,8 +34,8 @@ from multiprocessing import Pool
from linspector.config.parser import FullConfigParser from linspector.config.parser import FullConfigParser
from linspector.core.interface import LinspectorInterface from linspector.core.interface import LinspectorInterface
from linspector.core.job import Job from linspector.core.job import LinspectorJob
from linspector.core.scheduler import Scheduler from linspector.core.scheduler import LinspectorScheduler
from linspector.frontends.lish import LishFrontend from linspector.frontends.lish import LishFrontend
from linspector.tasks.task import TaskExecutor from linspector.tasks.task import TaskExecutor
@ -122,7 +122,7 @@ def main():
logger.error(msg) logger.error(msg)
exit() exit()
scheduler = Scheduler({"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})
scheduler.start() scheduler.start()
TaskExecutor.Instance() TaskExecutor.Instance()
@ -154,11 +154,11 @@ def main():
time_delta += float(args.delay) time_delta += float(args.delay)
new_start_date = start_date + datetime.timedelta(seconds=time_delta) new_start_date = start_date + datetime.timedelta(seconds=time_delta)
job = Job(service, job = LinspectorJob(service,
host, host,
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)
if scheduler_job is not None: if scheduler_job is not None:
job.set_job(scheduler_job) job.set_job(scheduler_job)