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