diff --git a/core/transfer/local/push.go b/core/transfer/local/push.go
index 0af2f7f45a5a..4ee4badfb224 100644
--- a/core/transfer/local/push.go
+++ b/core/transfer/local/push.go
@@ -158,7 +158,13 @@ func (p *progressPusher) WrapHandler(h images.Handler) images.Handler {
 func (p *progressPusher) Push(ctx context.Context, d ocispec.Descriptor) (content.Writer, error) {
 	ref := remotes.MakeRefKey(ctx, d)
 	p.status.add(ref, d)
-	cw, err := p.Pusher.Push(ctx, d)
+	var cw content.Writer
+	var err error
+	if cs, ok := p.Pusher.(content.Ingester); ok {
+		cw, err = content.OpenWriter(ctx, cs, content.WithRef(ref), content.WithDescriptor(d))
+	} else {
+		cw, err = p.Pusher.Push(ctx, d)
+	}
 	if err != nil {
 		if errdefs.IsAlreadyExists(err) {
 			p.progress.MarkExists(d)