From ff6b17177ee3d834b6f4b031eb3305e5ca30daa1 Mon Sep 17 00:00:00 2001 From: Dominik Schmidt Date: Thu, 16 Jul 2026 01:28:58 +0200 Subject: [PATCH] Apply suggestion from @dschmidt --- services/search/pkg/opensearch/batch.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/services/search/pkg/opensearch/batch.go b/services/search/pkg/opensearch/batch.go index 783de44762..3e535e8a05 100644 --- a/services/search/pkg/opensearch/batch.go +++ b/services/search/pkg/opensearch/batch.go @@ -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