Browse Source

Merge pull request #46494 from rumpl/c8d-fix-daemon-proxy

Djordje Lukic 1 year ago
parent
commit
24405e8044
1 changed files with 6 additions and 2 deletions
  1. 6 2
      daemon/containerd/image_pull.go

+ 6 - 2
daemon/containerd/image_pull.go

@@ -73,8 +73,14 @@ func (i *ImageService) PullImage(ctx context.Context, image, tagOrDigest string,
 	finishProgress := jobs.showProgress(ctx, out, pp)
 	defer finishProgress()
 
+	var sentPullingFrom bool
 	ah := images.HandlerFunc(func(ctx context.Context, desc ocispec.Descriptor) ([]ocispec.Descriptor, error) {
 		if images.IsManifestType(desc.MediaType) {
+			if !sentPullingFrom {
+				progress.Message(out, tagOrDigest, "Pulling from "+reference.Path(ref))
+				sentPullingFrom = true
+			}
+
 			available, _, _, missing, err := images.Check(ctx, i.client.ContentStore(), desc, p)
 			if err != nil {
 				return nil, err
@@ -98,8 +104,6 @@ func (i *ImageService) PullImage(ctx context.Context, image, tagOrDigest string,
 	infoHandler := snapshotters.AppendInfoHandlerWrapper(ref.String())
 	opts = append(opts, containerd.WithImageHandlerWrapper(infoHandler))
 
-	progress.Message(out, tagOrDigest, "Pulling from "+reference.Path(ref))
-
 	img, err := i.client.Pull(ctx, ref.String(), opts...)
 	if err != nil {
 		return err