@@ -21,7 +21,7 @@ import (
2121// It also evaluates that re-inserting is idempotent.
2222func TestChunkDataPacks_Store (t * testing.T ) {
2323 WithChunkDataPacks (t , 100 , func (t * testing.T , chunkDataPacks []* flow.ChunkDataPack , chunkDataPackStore * store.ChunkDataPacks , protocolDB storage.DB , chunkDataPackDB storage.DB , lockManager storage.LockManager ) {
24- require .NoError (t , unittest .WithLock (t , lockManager , storage .LockInsertOwnReceipt , func (lctx lockctx.Context ) error {
24+ require .NoError (t , unittest .WithLock (t , lockManager , storage .LockIndexChunkDataPackByChunkID , func (lctx lockctx.Context ) error {
2525
2626 storeFunc , err := chunkDataPackStore .Store (chunkDataPacks )
2727 if err != nil {
@@ -95,7 +95,7 @@ func TestChunkDataPacks_BatchRemove(t *testing.T) {
9595 }
9696
9797 // Store chunk data packs
98- require .NoError (t , unittest .WithLock (t , lockManager , storage .LockInsertOwnReceipt , func (lctx lockctx.Context ) error {
98+ require .NoError (t , unittest .WithLock (t , lockManager , storage .LockIndexChunkDataPackByChunkID , func (lctx lockctx.Context ) error {
9999 storeFunc , err := chunkDataPackStore .Store (chunkDataPacks )
100100 if err != nil {
101101 return err
@@ -154,7 +154,7 @@ func TestChunkDataPacks_BatchRemoveChunkDataPacksOnly(t *testing.T) {
154154 }
155155
156156 // Store chunk data packs
157- require .NoError (t , unittest .WithLock (t , lockManager , storage .LockInsertOwnReceipt , func (lctx lockctx.Context ) error {
157+ require .NoError (t , unittest .WithLock (t , lockManager , storage .LockIndexChunkDataPackByChunkID , func (lctx lockctx.Context ) error {
158158 storeFunc , err := chunkDataPackStore .Store (chunkDataPacks )
159159 if err != nil {
160160 return err
0 commit comments