|
@@ -125,6 +125,7 @@ func AddRunningCluster(taskCache entity.TaskCache, nodeName string) error {
|
|
|
node.Parallelism--
|
|
|
nodeJson, _ := GpuNodeToJson(node)
|
|
|
_, _ = infra.GlobalRedisClient.LSet(global.KeyGpuNodeList, int64(i), nodeJson).Result()
|
|
|
+ infra.GlobalLogger.Infof("节点 %v 并行度减一后剩余并行度为 %v。", node.Hostname, node.Parallelism)
|
|
|
}
|
|
|
}
|
|
|
global.ParallelismMutex.Unlock()
|