@@ -168,7 +168,7 @@ impl ArrowUnorderedBlockfileWriter {
168
168
value : V ,
169
169
) -> Result < ( ) , Box < dyn ChromaError > > {
170
170
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
171
- let ( _ , target_block_id) = loop {
171
+ let ( _guard , target_block_id) = loop {
172
172
// Get the target block id for the key
173
173
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
174
174
@@ -285,7 +285,7 @@ impl ArrowUnorderedBlockfileWriter {
285
285
key : K ,
286
286
) -> Result < Option < V :: PreparedValue > , Box < dyn ChromaError > > {
287
287
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
288
- let ( _ , target_block_id) = loop {
288
+ let ( _guard , target_block_id) = loop {
289
289
// Get the target block id for the key
290
290
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
291
291
@@ -357,7 +357,7 @@ impl ArrowUnorderedBlockfileWriter {
357
357
key : K ,
358
358
) -> Result < ( ) , Box < dyn ChromaError > > {
359
359
let search_key = CompositeKey :: new ( prefix. to_string ( ) , key. clone ( ) ) ;
360
- let ( _ , target_block_id) = loop {
360
+ let ( _guard , target_block_id) = loop {
361
361
// Get the target block id for the key
362
362
let target_block_id = self . root . sparse_index . get_target_block_id ( & search_key) ;
363
363
0 commit comments