实例失败不执行完结回调

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/FlowStatusServiceImpl.java

@@ -27,10 +27,6 @@ public class FlowStatusServiceImpl implements FlowStatusService {
                 return RunRecordingEnum.RUN_FLOW_KILL.getCode();
             }
 
-            if (RunRecordingEnum.RUN_FLOW_FAILURE.getCode().equals(runRecordingByFlowIdAndRunId.getFlowRunResult())) {
-                return RunRecordingEnum.RUN_FLOW_FAILURE.getCode();
-            }
-
             if (RunRecordingEnum.FAIL_FAST_YES.getCode().equals(runRecordingByFlowIdAndRunId.getFailFast())) {
                 return RunRecordingEnum.FAIL_FAST_YES.getCode();
             }

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JobTaskThreadRunHelper.java

@@ -3,6 +3,7 @@ package com.byit.thread.helper;
 import cn.hutool.core.collection.CollectionUtil;
 import com.byit.enums.FlowPropertyEnum;
 import com.byit.enums.NodeNameEnum;
+import com.byit.enums.RunRecordingEnum;
 import com.byit.enums.ScheduleTypeEnum;
 import com.byit.exceptions.SuperiorNodeRunException;
 import com.byit.flowservice.NodeVerification;
@@ -179,11 +180,14 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
      */
     private void updateRunRecording (Integer flowId, String runId) {
         RunRecording runRecordingByFlowIdAndRunId = runRecordingService.findRunRecordingByFlowIdAndRunId(flowId, runId);
+        if (!RunRecordingEnum.FAIL_FAST_YES.getCode().equals(runRecordingByFlowIdAndRunId.getFailFast())) {
             runRecordingByFlowIdAndRunId.setFlowStatus(FlowPropertyEnum.FLOW_RUN_ING.getCode());
             runRecordingByFlowIdAndRunId.setStartTime(new Date());
             runRecordingService.updateRunRecordingById(runRecordingByFlowIdAndRunId);
         }
 
+    }
+
     @Override
     public DataSource getDataSource() {
         return dataSource;