diff --git a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java index 9c748ec1..de879393 100644 --- a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java +++ b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ServiceVersionStatusTask.java @@ -44,7 +44,7 @@ public class ServiceVersionStatusTask { STATUS_URL = zsServiceVersionUrl + "/api/v1/getInferenceTaskAsync"; } -// @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次 + @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次 public void executeServiceVersionStatus() { try { // 1. 调用queryAllVersionList接口获取所有runState为RUNNING的数据 @@ -163,7 +163,7 @@ public class ServiceVersionStatusTask { /** * 新增定时任务:处理已完成的任务,获取URL */ -// @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次 + @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次 public void executeSetUrl() { try { // 1. 调用queryAllComplList接口获取所有runState为COMPLETED且url为空的数据 @@ -205,11 +205,11 @@ public class ServiceVersionStatusTask { */ @Scheduled(cron = "0 * * * * ?") // 每分钟执行一次 public void executeServiceStatusChange() { - try { - List completedVersions = serviceVersionMapper.queryAllRunList(); - if (completedVersions != null && !completedVersions.isEmpty()) { - for (ServiceVersionZs version : completedVersions) { + List runningVersions = serviceVersionMapper.queryAllRunList(); + if (runningVersions != null && !runningVersions.isEmpty()) { + try { + for (ServiceVersionZs version : runningVersions) { // 2. 过滤获取数据中的jobSetId字段 String jobSetId = version.getJobSetId(); if (jobSetId != null && !jobSetId.isEmpty()) { @@ -231,9 +231,9 @@ public class ServiceVersionStatusTask { } } } + } catch (Exception e) { + logger.error("Error executing service version URL task", e); } - } catch (Exception e) { - logger.error("Error executing service version URL task", e); } }