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

added job enable/disble stuff

Browse source
This commit is contained in:
Johannes Findeisen 2013-10-11 00:03:18 +02:00
commit e12e05dbc7
1 changed files with 17 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

26
linspector/core/job.py
View file

@ -41,6 +41,7 @@ class Job:
self.hostgroup = hostgroup self.hostgroup = hostgroup
self.jobInfos = [] self.jobInfos = []
self.jobThreshold = 0 self.jobThreshold = 0
self._enabled = True
def __str__(self): def __str__(self):
return str(self.__dict__) return str(self.__dict__)
@ -89,19 +90,26 @@ class Job:
def handle_call(self): def handle_call(self):
self.log.debug("handle call") self.log.debug("handle call")
self.log.debug(self.service) self.log.debug(self.service)
try: if self._enabled:
jobInfo = JobInfo(self.hex_string(), self.host, self.service) try:
self.service._execute(jobInfo) jobInfo = JobInfo(self.hex_string(), self.host, self.service)
jobInfo.set_execution_end() self.service._execute(jobInfo)
jobInfo.set_execution_end()
self.handle_threshold(jobInfo, self.service.get_threshold(), jobInfo.was_execution_successful()) self.handle_threshold(jobInfo, self.service.get_threshold(), jobInfo.was_execution_successful())
self.log.debug("Code: " + str(jobInfo.get_errorcode()) + ", Message: " + str(jobInfo.get_message())) self.log.debug("Code: " + str(jobInfo.get_errorcode()) + ", Message: " + str(jobInfo.get_message()))
self.jobInfos.append(jobInfo) self.jobInfos.append(jobInfo)
except Exception, e: except Exception, e:
self.log.debug(e) self.log.debug(e)
def enable(self):
self._enabled = True
def disable(self):
self._enabled = False
class JobInfo(object): class JobInfo(object):