| @@ -153,7 +153,8 @@ public class ActiveLearnInsServiceImpl implements ActiveLearnInsService { | |||||
| String phaseValue = (String) innerMap.get("phase"); | String phaseValue = (String) innerMap.get("phase"); | ||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | ||||
| innerMap.put("phase", Constant.Failed); | |||||
| innerMap.put("phase", Constant.Terminated); | |||||
| innerMap.put("finishedAt", new Date()); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| @@ -212,7 +212,8 @@ public class AutoMlInsServiceImpl implements AutoMlInsService { | |||||
| String phaseValue = (String) innerMap.get("phase"); | String phaseValue = (String) innerMap.get("phase"); | ||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | ||||
| innerMap.put("phase", Constant.Failed); | |||||
| innerMap.put("phase", Constant.Terminated); | |||||
| innerMap.put("finishedAt", new Date()); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| @@ -407,7 +407,8 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | ||||
| innerMap.put("phase", Constant.Failed); | |||||
| innerMap.put("phase", Constant.Terminated); | |||||
| innerMap.put("finishedAt", new Date()); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| @@ -217,7 +217,8 @@ public class MachineLearnInsServiceImpl implements MachineLearnInsService { | |||||
| String phaseValue = (String) innerMap.get("phase"); | String phaseValue = (String) innerMap.get("phase"); | ||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | ||||
| innerMap.put("phase", Constant.Failed); | |||||
| innerMap.put("phase", Constant.Terminated); | |||||
| innerMap.put("finishedAt", new Date()); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| @@ -161,7 +161,8 @@ public class RayInsServiceImpl implements RayInsService { | |||||
| String phaseValue = (String) innerMap.get("phase"); | String phaseValue = (String) innerMap.get("phase"); | ||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | ||||
| innerMap.put("phase", Constant.Failed); | |||||
| innerMap.put("phase", Constant.Terminated); | |||||
| innerMap.put("finishedAt", new Date()); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| @@ -163,7 +163,7 @@ public class WorkflowServiceImpl implements WorkflowService { | |||||
| if (experimentList != null && experimentList.size() > 0) { | if (experimentList != null && experimentList.size() > 0) { | ||||
| throw new Exception("该流水线存在实验,无法删除"); | throw new Exception("该流水线存在实验,无法删除"); | ||||
| } | } | ||||
| workflow.setState(0); | |||||
| workflow.setState(Constant.State_invalid); | |||||
| assetWorkflowDao.deleteByWorkFlowId(id); | assetWorkflowDao.deleteByWorkFlowId(id); | ||||
| return this.workflowDao.update(workflow) > 0 ? "删除成功" : "删除失败"; | return this.workflowDao.update(workflow) > 0 ? "删除成功" : "删除失败"; | ||||
| } | } | ||||