fix: Fix successful ES bulk request failing with cluster block messag…

…e due to cluster block handling fix
driskell · Jul 30, 2024 · 20e5751 · 20e5751
1 parent d5c1cc2
commit 20e5751
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lc-lib/transports/es/transportes.go b/lc-lib/transports/es/transportes.go
@@ -412,7 +412,7 @@ func (t *transportES) performBulkRequest(addr *addresspool.Address, id int, requ
 	}
 
 	// If cluster is blocked on all messages, allow a retry to occur by throwing an error
-	if clusterBlocked == len(response.Errors) {
+	if len(response.Errors) > 0 && clusterBlocked == len(response.Errors) {
 		return fmt.Errorf("cluster is blocked")
 	}