Fix writer errors

Signed-off-by: fpetkovski <filip.petkovsky@gmail.com>
thanos-io · Nov 26, 2022 · 0c6087b · 0c6087b
1 parent b002700
commit 0c6087b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go
@@ -777,7 +777,7 @@ func (h *Handler) fanoutForward(pctx context.Context, tenant string, wreqs map[e
 			if !more {
 				for _, rerr := range seriesErrs {
 					if seriesReplicated {
-						errs.Add(rerr.Cause())
+						errs.Add(rerr.ErrOrNil())
 					} else {
 						cause := rerr.replicationErr(quorum)
 						errs.Add(errors.Wrapf(cause, rerr.Error()))

diff --git a/pkg/receive/writer.go b/pkg/receive/writer.go
@@ -209,5 +209,5 @@ func (r *Writer) Write(ctx context.Context, tenantID string, wreq *prompb.WriteR
 	if err := app.Commit(); err != nil {
 		errs.Add(errors.Wrap(err, "commit samples"))
 	}
-	return errs.Cause()
+	return errs.ErrOrNil()
 }