commit

amd64/dispatch_server/package/handler/start_project.go

@@ -137,15 +137,17 @@ func StartProject(c *gin.Context) {
 		if domain.CanRunUser(userId, userParallelism) { // 可以运行
 			err := domain.AddWaitingCluster(userId, userParallelism, algorithmObjectKey, task)
 			if err != nil {
-				infra.GlobalLogger.Errorf("将任务 %v 添加到集群等待队列失败，错误信息为：%v", task, err)
+				infra.GlobalLogger.Errorf("将任务 %v 添加到【集群等待队列】失败，错误信息为：%v", task, err)
 				continue
 			}
+			infra.GlobalLogger.Infof("将任务 %v 添加到【集群等待队列】成功。", task.Info.TaskId)
 		} else { // 不能运行
 			err := domain.AddWaitingUser(userId, userParallelism, algorithmObjectKey, task)
 			if err != nil {
-				infra.GlobalLogger.Errorf("将任务 %v 添加到集群等待队列失败，错误信息为：%v", task, err)
+				infra.GlobalLogger.Errorf("将任务 %v 添加到【用户等待队列】失败，错误信息为：%v", task, err)
 				continue
 			}
+			infra.GlobalLogger.Infof("将任务 %v 添加到【用户等待队列】成功。", task.Info.TaskId)
 		}
 		global.RunTaskMutex.Unlock()
 	}