fixed taskExecutor execution
This commit is contained in:
parent
1b089807bb
commit
c2d8da3cad
1 changed files with 5 additions and 6 deletions
|
|
@ -86,13 +86,12 @@ class TaskExecutor(object):
|
||||||
self.event.wait()
|
self.event.wait()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
msg, taskInfos = self.taskInfos[0]
|
msg, task = self.taskInfos[0]
|
||||||
del self.taskInfos[0]
|
del self.taskInfos[0]
|
||||||
for taskInfo in taskInfos:
|
|
||||||
task = self.find_task_by_name(taskInfo["class"])
|
|
||||||
if task:
|
if task:
|
||||||
logger.debug("Starting Task Execution...")
|
logger.debug("Starting Task Execution...")
|
||||||
task.execute(msg, taskInfo["args"])
|
task.execute(msg)
|
||||||
|
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
logger.error("Error " + str(e))
|
logger.error("Error " + str(e))
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue