mlx

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/scheduler/ProjectScheduler.java

@@ -113,9 +113,12 @@ public class ProjectScheduler {
                             }
                         }
                     }
+                } else {
+                    run(clusterId, projectId, redisPrefix.getProjectWaitingKey(), redisPrefix.getProjectRunningKey());
                 }
+            } else {
+                run(clusterId, projectId, redisPrefix.getProjectWaitingKey(), redisPrefix.getProjectRunningKey());
             }
-            run(clusterId, projectId, redisPrefix.getProjectWaitingKey(), redisPrefix.getProjectRunningKey());
         }
     }
 
@@ -124,7 +127,7 @@ public class ProjectScheduler {
         String projectJson = redisTemplate.opsForValue().get(projectWaitingKey);
         redisTemplate.delete(projectWaitingKey);
         if (StringUtil.isEmpty(projectJson)) {
-            log.error("ProjectScheduler--run 项目 " + projectId + "的开始消息查询失败，key 为：" + projectWaitingKey);
+            log.error("ProjectScheduler--run 项目 " + projectId + " 的开始消息查询失败，key 为：" + projectWaitingKey);
             return;
         }
         redisTemplate.opsForValue().set(projectRunningKey, projectJson);