Commit b266d0aa authored by Samuel GAIST's avatar Samuel GAIST
Browse files

[execution][algorithm] Improve error handling during process

If process fails, return early and send done message to
other parties. This allows to stop everything more
cleanly.
parent d5359ab5
...@@ -256,14 +256,18 @@ class AlgorithmExecutor(object): ...@@ -256,14 +256,18 @@ class AlgorithmExecutor(object):
output=self.output_list[0], output=self.output_list[0],
) )
else: else:
result = self.runner.process( try:
inputs=self.input_list, result = self.runner.process(
data_loaders=self.data_loaders, inputs=self.input_list,
outputs=self.output_list, data_loaders=self.data_loaders,
loop_channel=self.loop_channel, outputs=self.output_list,
) loop_channel=self.loop_channel,
)
except Exception:
result = None
if not result: if not result:
self.done({})
return False return False
for output in self.output_list: for output in self.output_list:
......
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