| @@ -199,7 +199,6 @@ public class ActiveLearnServiceImpl implements ActiveLearnService { | |||||
| Map<String, String> output2 = (Map<String, String>) output1.get(0); | Map<String, String> output2 = (Map<String, String>) output1.get(0); | ||||
| String outputPath = output2.get("path").replace("{{workflow.name}}", (String) metadata.get("name")); | String outputPath = output2.get("path").replace("{{workflow.name}}", (String) metadata.get("name")); | ||||
| activeLearnIns.setResultPath(outputPath); | activeLearnIns.setResultPath(outputPath); | ||||
| activeLearnInsService.queryStatusFromArgo(activeLearnIns); | |||||
| activeLearnInsDao.insert(activeLearnIns); | activeLearnInsDao.insert(activeLearnIns); | ||||
| activeLearnInsService.updateActiveLearnStatus(id); | activeLearnInsService.updateActiveLearnStatus(id); | ||||
| // 记录开始扣除积分 | // 记录开始扣除积分 | ||||
| @@ -273,7 +273,6 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| @Override | @Override | ||||
| public ExperimentIns queryStatusFromArgo(ExperimentIns ins) { | public ExperimentIns queryStatusFromArgo(ExperimentIns ins) { | ||||
| String namespace = ins.getArgoInsNs(); | String namespace = ins.getArgoInsNs(); | ||||
| String name = ins.getArgoInsName(); | String name = ins.getArgoInsName(); | ||||
| Integer id = ins.getId(); | Integer id = ins.getId(); | ||||
| @@ -306,7 +306,6 @@ public class ExperimentServiceImpl implements ExperimentService { | |||||
| experimentIns.setMetricRecord(JacksonUtil.toJSONString(metricRecord)); | experimentIns.setMetricRecord(JacksonUtil.toJSONString(metricRecord)); | ||||
| } | } | ||||
| //插入ExperimentIns表中 | //插入ExperimentIns表中 | ||||
| experimentInsService.queryStatusFromArgo(experimentIns); | |||||
| ExperimentIns insert = experimentInsService.insert(experimentIns); | ExperimentIns insert = experimentInsService.insert(experimentIns); | ||||
| //插入到模型依赖关系表 | //插入到模型依赖关系表 | ||||
| if (dependendcy != null && trainInfo != null) { | if (dependendcy != null && trainInfo != null) { | ||||
| @@ -231,7 +231,6 @@ public class MachineLearnServiceImpl implements MachineLearnService { | |||||
| break; | break; | ||||
| } | } | ||||
| } | } | ||||
| machineLearnInsService.queryStatusFromArgo(machineLearnIns); | |||||
| machineLearnInsDao.insert(machineLearnIns); | machineLearnInsDao.insert(machineLearnIns); | ||||
| machineLearnInsService.updateMLStatus(id); | machineLearnInsService.updateMLStatus(id); | ||||
| if (computingResourceId != null) { | if (computingResourceId != null) { | ||||
| @@ -218,7 +218,6 @@ public class RayServiceImpl implements RayService { | |||||
| Map<String, String> output2 = (Map<String, String>) output1.get(0); | Map<String, String> output2 = (Map<String, String>) output1.get(0); | ||||
| String outputPath = output2.get("path").replace("{{workflow.name}}", (String) metadata.get("name")) + "/hpo"; | String outputPath = output2.get("path").replace("{{workflow.name}}", (String) metadata.get("name")) + "/hpo"; | ||||
| rayIns.setResultPath(outputPath); | rayIns.setResultPath(outputPath); | ||||
| rayInsService.queryStatusFromArgo(rayIns); | |||||
| rayInsDao.insert(rayIns); | rayInsDao.insert(rayIns); | ||||
| rayInsService.updateRayStatus(id); | rayInsService.updateRayStatus(id); | ||||
| // 记录开始扣除积分 | // 记录开始扣除积分 | ||||