From c2d8da3cadff97a9389f97a2ecf5f944820ca85b Mon Sep 17 00:00:00 2001 From: RafTim Date: Sat, 9 Nov 2013 02:26:16 +0100 Subject: [PATCH] fixed taskExecutor execution --- linspector/tasks/task.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/linspector/tasks/task.py b/linspector/tasks/task.py index 768e1de..7b47045 100644 --- a/linspector/tasks/task.py +++ b/linspector/tasks/task.py @@ -86,13 +86,12 @@ class TaskExecutor(object): self.event.wait() try: - msg, taskInfos = self.taskInfos[0] + msg, task = self.taskInfos[0] del self.taskInfos[0] - for taskInfo in taskInfos: - task = self.find_task_by_name(taskInfo["class"]) - if task: - logger.debug("Starting Task Execution...") - task.execute(msg, taskInfo["args"]) + if task: + logger.debug("Starting Task Execution...") + task.execute(msg) + except Exception, e: logger.error("Error " + str(e))