From c96c4d1e09e2047ffccc185d9a78f1885d10b773 Mon Sep 17 00:00:00 2001 From: Will Assis Date: Mon, 1 Dec 2025 14:59:46 -0300 Subject: [PATCH] use batch delete when rolling back bulkimport --- pkg/storage/unified/resource/storage_backend.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/pkg/storage/unified/resource/storage_backend.go b/pkg/storage/unified/resource/storage_backend.go index 44963298413..ead0c2245ed 100644 --- a/pkg/storage/unified/resource/storage_backend.go +++ b/pkg/storage/unified/resource/storage_backend.go @@ -1234,11 +1234,9 @@ func (b *kvStorageBackend) ProcessBulk(ctx context.Context, setting BulkSettings saved := make([]DataKey, 0) rollback := func() { // we don't have transactions in the kv store, so we simply delete everything we created - for _, val := range saved { - err = b.dataStore.Delete(ctx, val) - if err != nil { - b.log.Error("failed to delete during rollback: %s", err) - } + err = b.dataStore.batchDelete(ctx, saved) + if err != nil { + b.log.Error("failed to delete during rollback: %s", err) } }