From 8212473330654968ee27e6f7375a9340d4653c99 Mon Sep 17 00:00:00 2001
From: Will Assis <william@williamassis.com>
Date: Tue, 2 Dec 2025 14:51:09 -0300
Subject: [PATCH] fix

---
 pkg/storage/unified/sql/backend.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/storage/unified/sql/backend.go b/pkg/storage/unified/sql/backend.go
index b741906b739..2416609761d 100644
--- a/pkg/storage/unified/sql/backend.go
+++ b/pkg/storage/unified/sql/backend.go
@@ -96,7 +96,7 @@ func NewBackend(opts BackendOptions) (Backend, error) {
 		pollingInterval:         opts.PollingInterval,
 		watchBufferSize:         opts.WatchBufferSize,
 		storageMetrics:          opts.storageMetrics,
-		bulkLock:                resource.NewBulkLock(),
+		bulkLock:                &bulkLock{running: make(map[string]bool)},
 		simulatedNetworkLatency: opts.SimulatedNetworkLatency,
 		lastImportTimeMaxAge:    opts.LastImportTimeMaxAge,
 	}, nil
@@ -122,7 +122,7 @@ type backend struct {
 	dbProvider db.DBProvider
 	db         db.DB
 	dialect    sqltemplate.Dialect
-	bulkLock   *resource.BulkLock
+	bulkLock   *bulkLock
 
 	// watch streaming
 	//stream chan *resource.WatchEvent