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