From 0d9e3db28f937d97d9fbb852de3c51bce3bb7793 Mon Sep 17 00:00:00 2001 From: Johannes Findeisen Date: Sat, 9 Nov 2013 03:46:08 +0100 Subject: [PATCH] small fixes --- linspector/config/parser.py | 1 - linspector/tasks/task.py | 8 +++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/linspector/config/parser.py b/linspector/config/parser.py index 908f32d..56d13b7 100644 --- a/linspector/config/parser.py +++ b/linspector/config/parser.py @@ -153,7 +153,6 @@ class ConfigParser: items = items_func(obj) for clazzItem in items: try: - clazz = clazzItem["class"] mod = self._load_module(clazz, modPart) item = mod.create(clazzItem) diff --git a/linspector/tasks/task.py b/linspector/tasks/task.py index 7b47045..de22ed1 100644 --- a/linspector/tasks/task.py +++ b/linspector/tasks/task.py @@ -46,6 +46,9 @@ class Task(object): def get_task_type(self): return str(self.__class__) + def get_task_type_name(self): + return str(self._type) + def add_arguments(self, args): for key, val in args.items(): self._args[key] = val @@ -78,7 +81,6 @@ class TaskExecutor(object): self._running = True task_thread.start() - def _run_worker_thread(self): while self.is_running() or not self.instand_end(): if len(self.taskInfos) == 0: @@ -95,7 +97,7 @@ class TaskExecutor(object): except Exception, e: logger.error("Error " + str(e)) - def is_instand_end(self): + def is_instant_end(self): return self._instantEnd def is_running(self): @@ -110,4 +112,4 @@ class TaskExecutor(object): def schedule_task(self, msg, task): self.taskInfos.append((msg, task)) - self.event.set() + self.event.set() \ No newline at end of file