@@ -166,7 +166,7 @@ impl ArrowUnorderedBlockfileWriter {
166
166
value : V ,
167
167
) -> Result < ( ) , Box < dyn ChromaError > > {
168
168
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
169
- let ( _ , target_block_id) = loop {
169
+ let ( _guard , target_block_id) = loop {
170
170
// Get the target block id for the key
171
171
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
172
172
@@ -279,7 +279,7 @@ impl ArrowUnorderedBlockfileWriter {
279
279
key : K ,
280
280
) -> Result < Option < V :: PreparedValue > , Box < dyn ChromaError > > {
281
281
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
282
- let ( _ , target_block_id) = loop {
282
+ let ( _guard , target_block_id) = loop {
283
283
// Get the target block id for the key
284
284
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
285
285
@@ -347,7 +347,7 @@ impl ArrowUnorderedBlockfileWriter {
347
347
key : K ,
348
348
) -> Result < ( ) , Box < dyn ChromaError > > {
349
349
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
350
- let ( _ , target_block_id) = loop {
350
+ let ( _guard , target_block_id) = loop {
351
351
// Get the target block id for the key
352
352
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
353
353
0 commit comments