Apply suggestion from @dschmidt

This commit is contained in:
Dominik Schmidt committed 2026-10-27 10:55:36 +01:00
1 parent 8aef6c5c22
commit ff6b17177e
1 file changed
+13 -4
+13 -4
View File
@@ -247,12 +247,21 @@ func (b *Batch) Push() error {
case err != nil:
return fmt.Errorf("failed to execute bulk operations: %w", err)
case resp.Errors:
items, err := json.Marshal(resp.Items)
if err != nil {
return fmt.Errorf("failed to marshal bulk response: %w", err)
var failed []opensearchgoAPI.BulkRespItem
for _, item := range resp.Items {
for _, result := range item {
if result.Error != nil {
failed = append(failed, result)
}
}
}
return fmt.Errorf("failed to execute bulk operations, response: %s", items)
failures, err := json.Marshal(failed)
if err != nil {
return fmt.Errorf("failed to marshal bulk failures: %w", err)
}
return fmt.Errorf("failed to execute bulk operations, failures: %s", failures)
}
bulkOperations = nil