Commit 3ab8b2fe authored by Jerome Mariette's avatar Jerome Mariette
Browse files

No commit message

No commit message
parent 0f77e19b
......@@ -222,6 +222,9 @@ class Workflow(threading.Thread):
def get_components_nameid(self):
return self.component_nameids.keys()
def wf_execution_wrapper(self):
getattr(self, self.function)()
def run(self):
"""
Only require for Threading
......@@ -241,7 +244,7 @@ class Workflow(threading.Thread):
# if collecting components and running workflow has not been done yet
if self.step == 1:
try:
getattr(self, self.function)()
self.wf_execution_wrapper()
except SystemExit, e:
self.status = self.STATUS_FAILED
self.end_time = time.time()
......@@ -257,7 +260,7 @@ class Workflow(threading.Thread):
# if the workflow was a dynamic one
if self.step == 2:
try:
getattr(self, self.function)()
self.wf_execution_wrapper()
except SystemExit, e:
self.status = self.STATUS_FAILED
self.end_time = time.time()
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment