Do not log nil error in bulk indexer (#574) (#579)

Anaethelion · rockdaboot · web-flow · commit c76853802ab5 · 2022-12-27T12:28:19.000+01:00
Co-authored-by: Tim Rühsen &lt;tim.ruehsen@gmx.de&gt;
diff --git a/esutil/bulk_indexer.go b/esutil/bulk_indexer.go
@@ -592,7 +592,7 @@ func (w *worker) flush(ctx context.Context) error {
 		atomic.AddUint64(&w.bi.stats.numFailed, uint64(len(w.items)))
 		// TODO(karmi): Wrap error (include response struct)
 		if w.bi.config.OnError != nil {
-			w.bi.config.OnError(ctx, fmt.Errorf("flush: %s", err))
+			w.bi.config.OnError(ctx, fmt.Errorf("flush: %s", res.String()))
 		}
 		return fmt.Errorf("flush: %s", res.String())
 	}

Original file line number	Diff line number	Diff line change
`@@ -592,7 +592,7 @@ func (w *worker) flush(ctx context.Context) error {`
`592`	`592`	`atomic.AddUint64(&w.bi.stats.numFailed, uint64(len(w.items)))`
`593`	`593`	`// TODO(karmi): Wrap error (include response struct)`
`594`	`594`	`if w.bi.config.OnError != nil {`
`595`		`- w.bi.config.OnError(ctx, fmt.Errorf("flush: %s", err))`
	`595`	`+ w.bi.config.OnError(ctx, fmt.Errorf("flush: %s", res.String()))`
`596`	`596`	`}`
`597`	`597`	`return fmt.Errorf("flush: %s", res.String())`
`598`	`598`	`}`