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

small fixes

Browse source
This commit is contained in:
Johannes Findeisen 2013-11-09 03:46:08 +01:00
commit 0d9e3db28f
2 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
linspector/config/parser.py
View file

@ -153,7 +153,6 @@ class ConfigParser:
items = items_func(obj) items = items_func(obj)
for clazzItem in items: for clazzItem in items:
try: try:
clazz = clazzItem["class"] clazz = clazzItem["class"]
mod = self._load_module(clazz, modPart) mod = self._load_module(clazz, modPart)
item = mod.create(clazzItem) item = mod.create(clazzItem)

8
linspector/tasks/task.py
View file

@ -46,6 +46,9 @@ class Task(object):
def get_task_type(self): def get_task_type(self):
return str(self.__class__) return str(self.__class__)
def get_task_type_name(self):
return str(self._type)
def add_arguments(self, args): def add_arguments(self, args):
for key, val in args.items(): for key, val in args.items():
self._args[key] = val self._args[key] = val
@ -78,7 +81,6 @@ class TaskExecutor(object):
self._running = True self._running = True
task_thread.start() task_thread.start()
def _run_worker_thread(self): def _run_worker_thread(self):
while self.is_running() or not self.instand_end(): while self.is_running() or not self.instand_end():
if len(self.taskInfos) == 0: if len(self.taskInfos) == 0:
@ -95,7 +97,7 @@ class TaskExecutor(object):
except Exception, e: except Exception, e:
logger.error("Error " + str(e)) logger.error("Error " + str(e))
def is_instand_end(self): def is_instant_end(self):
return self._instantEnd return self._instantEnd
def is_running(self): def is_running(self):
@ -110,4 +112,4 @@ class TaskExecutor(object):
def schedule_task(self, msg, task): def schedule_task(self, msg, task):
self.taskInfos.append((msg, task)) self.taskInfos.append((msg, task))
self.event.set() self.event.set()