From 792eabc3b8c6a00f4f7a6373137f2bc4f047f6a2 Mon Sep 17 00:00:00 2001 From: Johannes Findeisen Date: Fri, 22 Nov 2013 17:52:32 +0100 Subject: [PATCH] small cleanups --- linspector/core/job.py | 4 +++- linspector/tasks/storage/mongodb.py | 10 ++++++---- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/linspector/core/job.py b/linspector/core/job.py index 22e5267..1644eaa 100644 --- a/linspector/core/job.py +++ b/linspector/core/job.py @@ -116,7 +116,9 @@ class Job: logger.debug(e) self.last_execution.set_execution_end() + self.handle_threshold(self.service.get_threshold(), self.last_execution.was_successful()) + logger.info("Job " + self.get_job_id() + ", Code: " + str(self.last_execution.get_error_code()) + ", Message: " + str(self.last_execution.get_message())) @@ -213,4 +215,4 @@ class JobInformation(object): return self.response_massage def set_response_message(self, msg): - self.response_massage = msg + self.response_massage = msg \ No newline at end of file diff --git a/linspector/tasks/storage/mongodb.py b/linspector/tasks/storage/mongodb.py index 7038769..2ede866 100644 --- a/linspector/tasks/storage/mongodb.py +++ b/linspector/tasks/storage/mongodb.py @@ -50,12 +50,14 @@ class MongodbTask(Task): if "port" in args: self.port = args["port"] - self.mongo_client = MongoClient(self.host, self.port) - self.mongo_db = self.mongo_client[self.database] - self.mongo_db_collection = self.mongo_db[self.collection] + #self.mongo_client = MongoClient(self.host, self.port) + #self.mongo_db = self.mongo_client[self.database] + #self.mongo_db_collection = self.mongo_db[self.collection] 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): return MongodbTask(**kwargs) \ No newline at end of file