.getFlowDescriptor();
String flowName = executionFlowDescriptor.getName();
- dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.TYPE_PHASE_START,
+ dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.PHASE_START,
"Flow " + flowName));
try {
if (autoUpgrade != null && autoUpgrade.equals("true"))
processThread.getExecutionModulesManager().upgrade(
realizedFlow.getModuleNameVersion());
+
+ // START FLOW
processThread.getExecutionModulesManager().execute(realizedFlow);
+ // END FLOW
} catch (Exception e) {
// TODO: re-throw exception ?
String msg = "Execution of flow " + flowName + " failed.";
log.error(msg, e);
- dispatchAddStep(new SlcExecutionStep(msg + " " + e.getMessage()));
+ dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.ERROR, msg
+ + " " + e.getMessage()));
processThread.notifyError();
} finally {
processThread.flowCompleted();
- dispatchAddStep(new SlcExecutionStep(
- SlcExecutionStep.TYPE_PHASE_END, "Flow " + flowName));
+ dispatchAddStep(new SlcExecutionStep(SlcExecutionStep.PHASE_END,
+ "Flow " + flowName));
}
}