diff --git a/cache/rebuilder.go b/cache/rebuilder.go index 479ab190..22d544b3 100644 --- a/cache/rebuilder.go +++ b/cache/rebuilder.go @@ -93,7 +93,7 @@ func (r rebuilder) Rebuild(srcs []string) error { wg.Wait() if errs.Err() != nil { - return fmt.Errorf("rebuild failed, %w", errs) + level.Warn(r.logger).Log("msg", "ignore archival, ", errs.Err()) } level.Info(r.logger).Log("msg", "cache built", "took", time.Since(now)) @@ -140,7 +140,7 @@ func (r rebuilder) rebuild(src, dst string) (err error) { tr := io.TeeReader(pr, sw) if err := r.s.Put(dst, tr); err != nil { - err = fmt.Errorf("upload file, pipe reader failed, %w", err) + err = fmt.Errorf("failed to upload file to cache storage, %w", err) if err := pr.CloseWithError(err); err != nil { level.Error(r.logger).Log("msg", "pr close", "err", err) } diff --git a/cache/restorer.go b/cache/restorer.go index 85458351..03e93205 100644 --- a/cache/restorer.go +++ b/cache/restorer.go @@ -124,7 +124,7 @@ func (r restorer) restore(src, dst string) (err error) { written, err := r.a.Extract(dst, pr) if err != nil { - err = fmt.Errorf("extract files from downloaded archive, pipe reader failed, %w", err) + err = fmt.Errorf("failed to extract files from downloaded archive, %w", err) if err := pr.CloseWithError(err); err != nil { level.Error(r.logger).Log("msg", "pr close", "err", err) }