|
@@ -227,7 +227,9 @@ func RunWaitingCluster() {
|
|
|
// 如果新算法需要导入
|
|
|
if !algorithmExist {
|
|
|
// 导入算法
|
|
|
+ infra.GlobalLogger.Infof("导入算法文件【%v】到docker镜像【%v】。", algorithmTarPath, algorithmImageNameWithVersion)
|
|
|
_, s, err := util.Execute("docker", "import", algorithmTarPath, algorithmImageNameWithVersion)
|
|
|
+ infra.GlobalLogger.Infof("推送算法镜像【%v】。", algorithmImageNameWithVersion)
|
|
|
_, s, err = util.Execute("docker", "push", algorithmImageNameWithVersion)
|
|
|
if err != nil {
|
|
|
infra.GlobalLogger.Errorf("导入算法镜像 %v 为 %v 失败,执行结果为:%v,错误信息为:%v", algorithmTarPath, algorithmImageNameWithVersion, s, err)
|