|
|
@@ -66,9 +66,6 @@ func RunWaitingUser() {
|
|
|
func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("启动【集群等待队列】监控进程。")
|
|
|
for {
|
|
|
- var algorithmTarName string
|
|
|
- var algorithmTarPath string
|
|
|
- var algorithmImageName string
|
|
|
|
|
|
time.Sleep(2 * time.Second)
|
|
|
global.GpuNodeListMutex.Lock()
|
|
|
@@ -79,7 +76,12 @@ func RunWaitingCluster() {
|
|
|
global.GpuNodeListMutex.Unlock()
|
|
|
continue
|
|
|
}
|
|
|
- var firstTaskCache entity.TaskCache
|
|
|
+ firstTaskCache := entity.TaskCache{}
|
|
|
+ algorithmTarName := ""
|
|
|
+ algorithmTarPath := ""
|
|
|
+ algorithmImageName := ""
|
|
|
+ newAlgorithm := false
|
|
|
+
|
|
|
if can {
|
|
|
//infra.GlobalLogger.Infof("节点 %v 有剩余并行度。", gpuNode)
|
|
|
// 判断是否有待运行的任务
|
