mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-07-31 17:59:49 -04:00
Code Issues Packages Projects Releases Wiki Activity

Apply suggestion from @dschmidt

Browse Source
This commit is contained in:
Dominik Schmidt
2026-07-16 01:28:58 +02:00
committed by GitHub
parent 9beb00afb0
commit 87dd68a04a
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
services/search/pkg/opensearch/batch.go
View File

@@ -211,12 +211,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