diff --git a/pkg/replicate/scheme.go b/pkg/replicate/scheme.go index 3910d80d0d..05d68991ad 100644 --- a/pkg/replicate/scheme.go +++ b/pkg/replicate/scheme.go @@ -200,7 +200,7 @@ func (rs *replicationScheme) execute(ctx context.Context) error { for id, meta := range metas { _, err := rs.fromBkt.ReaderWithExpectedErrs(rs.fromBkt.IsObjNotFoundErr).Get(ctx, path.Join(meta.ULID.String(), metadata.DeletionMarkFilename)) if err != nil && !rs.fromBkt.IsObjNotFoundErr(err) { - level.Debug(rs.logger).Log("msg", "failed to read deletion mark from origin bucket", "error", err) + return errors.Wrapf(err, "failed to read deletion mark from origin bucket block %s", meta.ULID.String()) } if rs.blockFilter(meta, !rs.fromBkt.IsObjNotFoundErr(err)) { level.Info(rs.logger).Log("msg", "adding block to be replicated", "block_uuid", id.String())