diff --git a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/RayInsStatusTask.java b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/RayInsStatusTask.java index 2bd5d429..717ab1ee 100644 --- a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/RayInsStatusTask.java +++ b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/RayInsStatusTask.java @@ -42,9 +42,9 @@ public class RayInsStatusTask { //当原本状态为null或非终止态时才调用argo接口 try { rayIns = rayInsService.queryStatusFromArgo(rayIns); - + Ray ray = rayDao.getRayById(rayIns.getRayId()); // 扣除积分 - if (Constant.Running.equals(rayIns.getStatus())) { + if (Constant.Running.equals(rayIns.getStatus()) && resourceOccupyService.haveResource(ray.getComputingResourceId(), 1)) { resourceOccupyService.deducing(Constant.TaskType_Ray, null, rayIns.getId(), null, null); } else if (Constant.Failed.equals(rayIns.getStatus()) || Constant.Terminated.equals(rayIns.getStatus()) || Constant.Succeeded.equals(rayIns.getStatus())) {