From e7d1c97a48c2874ddf0c9607d76ebe0840a88635 Mon Sep 17 00:00:00 2001
From: Johannes Findeisen <you@hanez.org>
Date: Sat, 9 Nov 2013 04:29:49 +0100
Subject: [PATCH] execute tasks nly of right type

---
 examples/dev.json      | 6 +++---
 linspector/core/job.py | 7 +++++--
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/examples/dev.json b/examples/dev.json
index 0d9724f..83c3526 100644
--- a/examples/dev.json
+++ b/examples/dev.json
@@ -42,7 +42,7 @@
         }
     },
     "periods": {
-        "fast": { "seconds": 15 },
+        "fast": { "seconds": 3 },
         "medium": { "seconds": 120 },
         "slow": { "seconds": 480 }
     },
@@ -54,14 +54,14 @@
                 {
                     "class": "etc/dummy",
                     "periods": ["fast"],
-                    "threshold": 1,
+                    "threshold": 10,
                     "args": { "sleep": 1, "fail": true }
                 },
                 {
                     "class": "etc/dummy",
                     "periods": ["fast"],
                     "threshold": 1,
-                    "args": { "sleep": 10, "fail": false }
+                    "args": { "sleep": 1, "fail": false }
                 }
             ]
         },
diff --git a/linspector/core/job.py b/linspector/core/job.py
index 2dded36..49ac703 100644
--- a/linspector/core/job.py
+++ b/linspector/core/job.py
@@ -108,12 +108,15 @@ class Job:
         if self.job_threshold >= service_threshold:
             logger.info("Job " + self.hex_string() + ", Threshold reached!")
             self.status = "ERROR"
-            self.handle_alarm()
+
+        self.handle_alarm()
 
     def handle_alarm(self):
         for member in self.members:
             for task in member.get_tasks():
-                TaskExecutor.Instance().schedule_task(self.get_message(), task)
+                if self.status.lower() == task.get_task_type_name():
+                    logger.debug("Executing Task of type: " + self.status)
+                    TaskExecutor.Instance().schedule_task(self.status + " " + self.get_message(), task)
 
     def handle_call(self):
         logger.debug("handle call")