fixes

internal/commands/copy.go

@@ -7,6 +7,8 @@ import (
 	"sync"
 	"time"
 
+	"golang.org/x/sync/errgroup"
+
 	"github.com/containers/image/v5/copy"
 	dockerv5 "github.com/containers/image/v5/docker"
 	"github.com/containers/image/v5/signature"
@@ -88,22 +90,24 @@ func runCopyCommand() error {
 	var sourcesToCopy []manifest.Source
 
 	for _, source := range sources {
-		errs.Go(func() error {
+		source := source
 
+		errs.Go(func() error {
 			exists, err := client.ImageExistsAtRemote(errCtx, source.TargetImage())
 			if err != nil {
 				return fmt.Errorf("image exists at remote: %w", err)
 			}
 
 			if !exists || viper.GetBool("force") {
-				m.Lock()
+				mu.Lock()
 				sourcesToCopy = append(sourcesToCopy, source)
-				m.Unlock()
+				mu.Unlock()
 			}
 
+			return nil
 		})
 	}
-	
+
 	if err := errs.Wait(); err != nil {
 		return err
 	}
@@ -151,12 +155,12 @@ func runCopyCommand() error {
 		log.Infof("Copying image %s to %s", source.Image(), source.TargetImage())
 		destRef, err := imageTransport.ParseReference(fmt.Sprintf("//%s", source.TargetImage()))
 		if err != nil {
-			return fmt.Errorf("Error parsing target image reference: %w", err)
+			return fmt.Errorf("unable to parse target image reference: %w", err)
 		}
 
 		srcRef, err := imageTransport.ParseReference(fmt.Sprintf("//%s", source.Image()))
 		if err != nil {
-			return fmt.Errorf("Error parsing source image reference: %w", err)
+			return fmt.Errorf("unable to parse source image reference: %w", err)
 		}
 
 		if _, err := copy.Image(ctx, policyContext, destRef, srcRef, &copyOptions); err != nil {