Commit 833046d8 by huangfusuper

增加快速失败标识

parent 9b4a0967
...@@ -122,6 +122,8 @@ public class RunNodeServiceImpl implements RunNodeServer, ApplicationEventPublis ...@@ -122,6 +122,8 @@ public class RunNodeServiceImpl implements RunNodeServer, ApplicationEventPublis
build.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode()); build.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode());
build.setFlowRunResult(RunResultEnum.RUN_ERROR.getCode()); build.setFlowRunResult(RunResultEnum.RUN_ERROR.getCode());
build.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode()); build.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode());
build.setStartTime(new Date());
build.setEndTime(new Date());
} }
//开始正式保存 //开始正式保存
runRecordingService.saveRunRecording(build); runRecordingService.saveRunRecording(build);
......
...@@ -283,6 +283,8 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask ...@@ -283,6 +283,8 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
runRecording.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode()); runRecording.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode());
runRecording.setFlowRunResult(RunResultEnum.RUN_ERROR.getCode()); runRecording.setFlowRunResult(RunResultEnum.RUN_ERROR.getCode());
runRecording.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode()); runRecording.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode());
runRecording.setStartTime(new Date());
runRecording.setEndTime(new Date());
} }
runRecordingService.updateRunRecordingById(runRecording); runRecordingService.updateRunRecordingById(runRecording);
......
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