| @@ -155,6 +155,7 @@ public class ActiveLearnInsServiceImpl implements ActiveLearnInsService { | |||||
| ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ||||
| ins.setStatus(Constant.Terminated); | ins.setStatus(Constant.Terminated); | ||||
| ins.setUpdateTime(new Date()); | ins.setUpdateTime(new Date()); | ||||
| ins.setFinishTime(new Date()); | |||||
| activeLearnInsDao.update(ins); | activeLearnInsDao.update(ins); | ||||
| updateActiveLearnStatus(ins.getActiveLearnId()); | updateActiveLearnStatus(ins.getActiveLearnId()); | ||||
| // 结束扣积分 | // 结束扣积分 | ||||
| @@ -219,6 +219,7 @@ public class AutoMlInsServiceImpl implements AutoMlInsService { | |||||
| ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ||||
| ins.setStatus(Constant.Terminated); | ins.setStatus(Constant.Terminated); | ||||
| ins.setUpdateTime(new Date()); | ins.setUpdateTime(new Date()); | ||||
| ins.setFinishTime(new Date()); | |||||
| this.autoMlInsDao.update(ins); | this.autoMlInsDao.update(ins); | ||||
| updateAutoMlStatus(autoMlIns.getAutoMlId()); | updateAutoMlStatus(autoMlIns.getAutoMlId()); | ||||
| return true; | return true; | ||||
| @@ -402,14 +402,15 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| String phaseValue = (String) innerMap.get("phase"); | String phaseValue = (String) innerMap.get("phase"); | ||||
| // 如果值不等于 Succeeded,则赋值为 Failed | // 如果值不等于 Succeeded,则赋值为 Failed | ||||
| if (!StringUtils.equals("Succeeded", phaseValue)) { | |||||
| innerMap.put("phase", "Failed"); | |||||
| if (!StringUtils.equals(Constant.Succeeded, phaseValue)) { | |||||
| innerMap.put("phase", Constant.Failed); | |||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| ins.setNodesStatus(JsonUtils.mapToJson(nodeMap)); | ins.setNodesStatus(JsonUtils.mapToJson(nodeMap)); | ||||
| ins.setStatus("Terminated"); | |||||
| ins.setStatus(Constant.Terminated); | |||||
| ins.setFinishTime(new Date()); | ins.setFinishTime(new Date()); | ||||
| ins.setUpdateTime(new Date()); | |||||
| this.experimentInsDao.update(ins); | this.experimentInsDao.update(ins); | ||||
| //删除数据集模型导出版本 | //删除数据集模型导出版本 | ||||
| @@ -168,6 +168,7 @@ public class RayInsServiceImpl implements RayInsService { | |||||
| ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ins.setNodeStatus(JsonUtils.mapToJson(nodeMap)); | ||||
| ins.setStatus(Constant.Terminated); | ins.setStatus(Constant.Terminated); | ||||
| ins.setUpdateTime(new Date()); | ins.setUpdateTime(new Date()); | ||||
| ins.setFinishTime(new Date()); | |||||
| rayInsDao.update(ins); | rayInsDao.update(ins); | ||||
| updateRayStatus(rayIns.getRayId()); | updateRayStatus(rayIns.getRayId()); | ||||
| // 结束扣积分 | // 结束扣积分 | ||||