fix: retain full error information for blocking writes (#293)

influxdata · Dec 22, 2021 · 0c248b5 · 0c248b5
1 parent 4218b50
commit 0c248b5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/api/writeAPIBlocking.go b/api/writeAPIBlocking.go
@@ -6,6 +6,7 @@ package api
 
 import (
 	"context"
+	"reflect"
 	"strings"
 
 	http2 "github.com/influxdata/influxdb-client-go/v2/api/http"
@@ -73,10 +74,10 @@ func NewWriteAPIBlocking(org string, bucket string, service http2.Service, write
 
 func (w *writeAPIBlocking) write(ctx context.Context, line string) error {
 	err := w.service.WriteBatch(ctx, iwrite.NewBatch(line, w.writeOptions.RetryInterval(), w.writeOptions.MaxRetryTime()))
-	if err != nil {
-		return err.Unwrap()
+	if reflect.ValueOf(err).IsNil() {
+		return nil
 	}
-	return nil
+	return err
 }
 
 func (w *writeAPIBlocking) WriteRecord(ctx context.Context, line ...string) error {