tijiao

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/app/service/ProjectApplicationService.java

@@ -1025,8 +1025,7 @@ public class ProjectApplicationService {
         projectDomainService.checkAlgorithmIsExpand(projectType, projectId, DictConstants.ALGORITHM_EXPAND_STATUS_NOT_TESTED);
     }
 
-    // TODO 暂时注释
-//    @Async("pool1")
+    @Async("pool1")
     public void runMultiProject(MultiSimulationProjectKafkaParam projectStartMessageEntity) {
         MultiProjectWaitQueueEntity multiTaskAndFixData = createMultiTaskAndFixData(projectStartMessageEntity);
         checkIfCanRunMulti(multiTaskAndFixData);

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/app/service/TaskApplicationService.java

@@ -229,6 +229,7 @@ public class TaskApplicationService {
 
     @Async
     public void multiState(String taskId, String state, String podName) {
+        log.info("多模式仿真任务反馈状态taskId:{},state:{},podName:{}", taskId, state, podName);
         MultiSimulationProjectTaskRecordPO taskEntity = multiTaskRecordMapper.selectMultiSimulationProjectTaskRecordById(taskId);
         if (taskEntity == null) {
             log.info("多模式仿真收到不存在的任务的状态消息：" + taskId);