diff --git a/pkg/kdk/pull.go b/pkg/kdk/pull.go index 7764d1b..6446415 100644 --- a/pkg/kdk/pull.go +++ b/pkg/kdk/pull.go @@ -24,7 +24,12 @@ import ( ) func Pull(cfg *KdkEnvConfig) error { - out, err := cfg.DockerClient.ImagePull(cfg.Ctx, cfg.ImageCoordinates(), types.ImagePullOptions{}) + return pullImage(cfg, cfg.ImageCoordinates()) +} + +func pullImage(cfg *KdkEnvConfig, imageCoordinates string) error { + + out, err := cfg.DockerClient.ImagePull(cfg.Ctx, imageCoordinates, types.ImagePullOptions{}) if err != nil { return err } diff --git a/pkg/kdk/update.go b/pkg/kdk/update.go index 513e9be..2aab339 100644 --- a/pkg/kdk/update.go +++ b/pkg/kdk/update.go @@ -113,7 +113,7 @@ func Update(cfg *KdkEnvConfig) { if needsUpdateImage(cfg) { log.Info("Updating KDK image") - err := updateImage(cfg) + err := pullImage(cfg, cfg.ConfigFile.AppConfig.ImageRepository + ":" + latestReleaseVersion) if err != nil { log.WithField("error", err).Fatal("Failed to update KDK image") }