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

small cleanups

Browse source
This commit is contained in:
Johannes Findeisen 2013-11-22 17:52:32 +01:00
commit 792eabc3b8
2 changed files with 9 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
linspector/core/job.py
View file

@ -116,7 +116,9 @@ class Job:
logger.debug(e) logger.debug(e)
self.last_execution.set_execution_end() self.last_execution.set_execution_end()
self.handle_threshold(self.service.get_threshold(), self.last_execution.was_successful()) self.handle_threshold(self.service.get_threshold(), self.last_execution.was_successful())
logger.info("Job " + self.get_job_id() + logger.info("Job " + self.get_job_id() +
", Code: " + str(self.last_execution.get_error_code()) + ", Code: " + str(self.last_execution.get_error_code()) +
", Message: " + str(self.last_execution.get_message())) ", Message: " + str(self.last_execution.get_message()))
@ -213,4 +215,4 @@ class JobInformation(object):
return self.response_massage return self.response_massage
def set_response_message(self, msg): def set_response_message(self, msg):
self.response_massage = msg self.response_massage = msg

10
linspector/tasks/storage/mongodb.py
View file

@ -50,12 +50,14 @@ class MongodbTask(Task):
if "port" in args: if "port" in args:
self.port = args["port"] self.port = args["port"]
self.mongo_client = MongoClient(self.host, self.port) #self.mongo_client = MongoClient(self.host, self.port)
self.mongo_db = self.mongo_client[self.database] #self.mongo_db = self.mongo_client[self.database]
self.mongo_db_collection = self.mongo_db[self.collection] #self.mongo_db_collection = self.mongo_db[self.collection]
def execute(self, job_information): def execute(self, job_information):
self.mongo_db_collection.insert(job_information.__dict__) #self.mongo_db_collection.insert(job_information.__dict__)
pass
def create(kwargs): def create(kwargs):
return MongodbTask(**kwargs) return MongodbTask(**kwargs)