update reconn nm

nm/start.go

@@ -96,15 +96,16 @@ func StartMonitor() {
 					}
 					if !managerClient.IsDel {
 						// TODO: 重试连接三次
-						managerClient.UpdateLastHeartTime(time.Now())
-						isSuccess := inputNodeManagerChan(manager, managerClient, managerClient.IsSelected, monitorNm)
+						//managerClient.UpdateLastHeartTime(time.Now())
+						managerClient.IsDel = true
+						isSuccess := inputNodeManagerChan(manager, nil, managerClient.IsSelected, monitorNm)
 						log.WithField("is success", isSuccess).Warn("Try to connect node manager client:", manager.Info.Endpoint)
 						if isSuccess {
 							log.Info("Connect node manager client success:", manager.Info.Endpoint)
 							continue
 						}
 					}
-					managerClient.IsDel = true
+					//managerClient.IsDel = true
 					log.WithField("Endpoint", managerClient.Endpoint).Warn("Node manager client is deleted")
 					unUsedNodeManagers := getUnUsedNodeManagers()
 					if unUsedNodeManagers == nil || len(unUsedNodeManagers) == 0 {

utils/util.go

@@ -144,6 +144,9 @@ func MatchFileCacheQueryString(params map[string][]string, taskImageName string,
 	isModelExistFileExpires := false
 	if !isExistFileExpires {
 		for _, info := range modelsInfo {
+			if info == nil {
+				continue
+			}
 			if info.ImageName == taskImageName && info.FileExpiresTime != "" {
 				values.Add(models.ResultFileExpiresDB, info.FileExpiresTime)
 				isModelExistFileExpires = true