|
@@ -98,6 +98,7 @@ func RunWaitingCluster() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// --------------- 下载算法 ---------------
|
|
// --------------- 下载算法 ---------------
|
|
|
|
|
+ infra.GlobalLogger.Infof("开始下载算法 %v。", firstTaskCache.AlgorithmObjectKey)
|
|
|
algorithmTarName = filepath.Base(firstTaskCache.AlgorithmObjectKey)
|
|
algorithmTarName = filepath.Base(firstTaskCache.AlgorithmObjectKey)
|
|
|
algorithmTarPath = infra.ApplicationYaml.K8s.AlgorithmTarTempDir + algorithmTarName
|
|
algorithmTarPath = infra.ApplicationYaml.K8s.AlgorithmTarTempDir + algorithmTarName
|
|
|
algorithmImageName = infra.ApplicationYaml.K8s.RegistryUri + "/cicvdcl_" + util.MD5HashShort(algorithmTarName)
|
|
algorithmImageName = infra.ApplicationYaml.K8s.RegistryUri + "/cicvdcl_" + util.MD5HashShort(algorithmTarName)
|
|
@@ -107,6 +108,7 @@ func RunWaitingCluster() {
|
|
|
time.Sleep(time.Duration(2) * time.Second)
|
|
time.Sleep(time.Duration(2) * time.Second)
|
|
|
continue
|
|
continue
|
|
|
}
|
|
}
|
|
|
|
|
+ infra.GlobalLogger.Infof("下载算法 %v 成功。", firstTaskCache.AlgorithmObjectKey)
|
|
|
|
|
|
|
|
firstTaskCache, err = JsonToTaskCache(firstTaskCacheJson)
|
|
firstTaskCache, err = JsonToTaskCache(firstTaskCacheJson)
|
|
|
if err != nil {
|
|
if err != nil {
|
