Browse Source

优化终止实验时间停止

pull/225/head
chenzhihang 9 months ago
parent
commit
72f85dbba5
4 changed files with 7 additions and 3 deletions
  1. +1
    -0
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ActiveLearnInsServiceImpl.java
  2. +1
    -0
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/AutoMlInsServiceImpl.java
  3. +4
    -3
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentInsServiceImpl.java
  4. +1
    -0
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/RayInsServiceImpl.java

+ 1
- 0
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ActiveLearnInsServiceImpl.java View File

@@ -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());
// 结束扣积分 // 结束扣积分


+ 1
- 0
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/AutoMlInsServiceImpl.java View File

@@ -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;


+ 4
- 3
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentInsServiceImpl.java View File

@@ -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);


//删除数据集模型导出版本 //删除数据集模型导出版本


+ 1
- 0
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/RayInsServiceImpl.java View File

@@ -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());
// 结束扣积分 // 结束扣积分


Loading…
Cancel
Save