Do not drop item after flush() failed (#623)

rockdaboot · web-flow · commit 39a695467b18 · 2023-03-22T14:05:18.000+01:00
diff --git a/esutil/bulk_indexer.go b/esutil/bulk_indexer.go
@@ -441,7 +441,8 @@ func (w *worker) run() {
 					if w.bi.config.OnError != nil {
 						w.bi.config.OnError(ctx, err)
 					}
-					continue
+					w.mu.Lock()
+					// continue with 'item' even when flush failed
 				}
 			}
 

Original file line number	Diff line number	Diff line change
`@@ -441,7 +441,8 @@ func (w *worker) run() {`
`441`	`441`	`if w.bi.config.OnError != nil {`
`442`	`442`	`w.bi.config.OnError(ctx, err)`
`443`	`443`	`}`
`444`		`- continue`
	`444`	`+ w.mu.Lock()`
	`445`	`+ // continue with 'item' even when flush failed`
`445`	`446`	`}`
`446`	`447`	`}`
`447`	`448`