|
|
@@ -129,8 +129,8 @@ func RunWaitingCluster() {
|
|
|
_ = util.CreateParentDir(algorithmTarPath)
|
|
|
algorithmImageName = infra.ApplicationYaml.K8s.RegistryUri + "/cicvdcl_" + util.MD5HashShort(algorithmTarName)
|
|
|
algorithmImageNameWithVersion = algorithmImageName + ":latest"
|
|
|
- newAlgorithm = util.ImageExists(infra.GlobalDockerClient, algorithmImageName)
|
|
|
- if newAlgorithm {
|
|
|
+ algorithmExist := util.ImageExists(infra.GlobalDockerClient, algorithmImageName)
|
|
|
+ if !algorithmExist {
|
|
|
if firstTaskCache.EquipmentType == "JIN_LONG_BA_SHI" || firstTaskCache.EquipmentType == "PU_JIN_DUO_GONG_NENG_CHE" {
|
|
|
err = infra.GlobalOssBucketCicv.GetObjectToFile(firstTaskCache.AlgorithmObjectKey, algorithmTarPath)
|
|
|
} else {
|
