From 87dd68a04a00c22d5807d7e93d85da5f519dfa89 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 af878a235f..8366a3a24f 100644 --- a/services/search/pkg/opensearch/batch.go +++ b/services/search/pkg/opensearch/batch.go @@ -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