Browse Source

优化更新实验状态

dev-czh
chenzhihang 1 year ago
parent
commit
f023bc59f3
1 changed files with 5 additions and 0 deletions
  1. +5
    -0
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java

+ 5
- 0
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java View File

@@ -34,6 +34,7 @@ public class ExperimentInstanceStatusTask {
// 首先查到所有非终止态的实验实例 // 首先查到所有非终止态的实验实例
List<ExperimentIns> experimentInsList = experimentInsService.queryByExperimentIsNotTerminated(); List<ExperimentIns> experimentInsList = experimentInsService.queryByExperimentIsNotTerminated();
// 去argo查询状态 // 去argo查询状态
List<ExperimentIns> updateList = new ArrayList<>();
if (experimentInsList != null && experimentInsList.size() > 0) { if (experimentInsList != null && experimentInsList.size() > 0) {
for (ExperimentIns experimentIns : experimentInsList) { for (ExperimentIns experimentIns : experimentInsList) {
//当原本状态为null或非终止态时才调用argo接口 //当原本状态为null或非终止态时才调用argo接口
@@ -48,6 +49,10 @@ public class ExperimentInstanceStatusTask {
synchronized (experimentIds) { synchronized (experimentIds) {
experimentIds.add(experimentIns.getExperimentId()); experimentIds.add(experimentIns.getExperimentId());
} }
updateList.add(experimentIns);
}
if (updateList.size() > 0) {
experimentInsDao.insertOrUpdateBatch(updateList);
} }
} }
} }


Loading…
Cancel
Save