Commit 3590fcb8 authored by Klaus Wölfel's avatar Klaus Wölfel

Introduce return code 1 to automatically re-execute data operation

parent b03f594a
...@@ -38,8 +38,11 @@ for analysis_line in context.objectValues(portal_type="Data Analysis Line"): ...@@ -38,8 +38,11 @@ for analysis_line in context.objectValues(portal_type="Data Analysis Line"):
script_id = operation.getScriptId() script_id = operation.getScriptId()
out = getattr(operation_analysis_line, script_id)(**parameter_dict) out = getattr(operation_analysis_line, script_id)(**parameter_dict)
# only stop batch ingestions if out == 1:
if use == "big_data/ingestion/batch": context.activate(serialization_tag=str(context.getUid())).DataAnalysis_executeDataOperation()
else:
# only stop batch ingestions
if use == "big_data/ingestion/batch":
context.stop() context.stop()
return out return out
Markdown is supported
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