fix: handle push error for internal cache (#544)

Signed-off-by: Billy Zha <[email protected]>
oras-project · Sep 8, 2022 · 45a1024 · 45a1024
1 parent 9ea7aee
commit 45a1024
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/cache/target.go b/internal/cache/target.go
@@ -78,6 +78,9 @@ func (t *target) cacheReadCloser(ctx context.Context, rc io.ReadCloser, target o
 	go func() {
 		defer wg.Done()
 		pushErr = t.cache.Push(ctx, target, pr)
+		if pushErr != nil {
+			pr.CloseWithError(pushErr)
+		}
 	}()
 
 	return struct {