commit

amd64/dispatch_server/main.go

@@ -73,9 +73,9 @@ func main() {
 	api1 := router.Group(infra.ApplicationYaml.Web.RoutePrefix)
 	api1.POST("/start-project", handler.StartProject)
 	api2 := router.Group("/simulation/resource/scheduler")
-	api2.POST("/confirm", handler.Confirm)
-	api2.POST("/tick", handler.Tick)
-	api2.POST("/state", handler.State)
+	api2.GET("/confirm", handler.Confirm)
+	api2.GET("/tick", handler.Tick)
+	api2.GET("/state", handler.State)
 	err := router.Run(":" + infra.ApplicationYaml.Web.Port)
 	if err != nil {
 		infra.GlobalLogger.Error("程序崩溃，监听端口 " + util.ToString(infra.ApplicationYaml.Web.Port) + " 失败。")

amd64/dispatch_server/package/service/run_task.go

@@ -81,11 +81,11 @@ func RunWaitingCluster() {
 		}
 		var firstTaskCache entity.TaskCache
 		if can {
-			infra.GlobalLogger.Infof("节点 %v 有剩余并行度。", gpuNode)
+			//infra.GlobalLogger.Infof("节点 %v 有剩余并行度。", gpuNode)
 			// 判断是否有待运行的任务
 			waitingClusterNumber, _ := infra.GlobalRedisClient.LLen(global.KeyTaskQueueWaitingCluster).Result()
 			if waitingClusterNumber == 0 {
-				infra.GlobalLogger.Info("集群没有等待运行的任务。")
+				//infra.GlobalLogger.Info("集群没有等待运行的任务。")
 				global.GpuNodeListMutex.Unlock()
 				continue
 			} else {