diff --git a/crates/milli/src/update/new/indexer/document_changes.rs b/crates/milli/src/update/new/indexer/document_changes.rs index 3e2b9c036..a45fcee85 100644 --- a/crates/milli/src/update/new/indexer/document_changes.rs +++ b/crates/milli/src/update/new/indexer/document_changes.rs @@ -206,7 +206,7 @@ pub fn extract< doc_allocs, fields_ids_map_store, must_stop_processing, - progress: send_progress, + progress, }: IndexingContext<'fid, 'indexer, 'index, MSP>, extractor_allocs: &'extractor mut ThreadLocal>, datastore: &'data ThreadLocal, @@ -217,7 +217,7 @@ where MSP: Fn() -> bool + Sync, { tracing::trace!("We are resetting the extractor allocators"); - send_progress.update_progress(step); + progress.update_progress(step); // Clean up and reuse the extractor allocs for extractor_alloc in extractor_allocs.iter_mut() { tracing::trace!("\tWith {} bytes reset", extractor_alloc.0.allocated_bytes()); @@ -226,7 +226,7 @@ where let total_documents = document_changes.len() as u32; let (step, progress_step) = AtomicDocumentStep::new(total_documents); - send_progress.update_progress(progress_step); + progress.update_progress(progress_step); let pi = document_changes.iter(CHUNK_SIZE); pi.try_arc_for_each_try_init( diff --git a/crates/milli/src/update/new/indexer/mod.rs b/crates/milli/src/update/new/indexer/mod.rs index acdf78304..a850c0d03 100644 --- a/crates/milli/src/update/new/indexer/mod.rs +++ b/crates/milli/src/update/new/indexer/mod.rs @@ -72,7 +72,7 @@ pub fn index<'pl, 'indexer, 'index, DC, MSP>( document_changes: &DC, embedders: EmbeddingConfigs, must_stop_processing: &'indexer MSP, - send_progress: &'indexer Progress, + progress: &'indexer Progress, ) -> Result<()> where DC: DocumentChanges<'pl>, @@ -125,7 +125,7 @@ where doc_allocs: &doc_allocs, fields_ids_map_store: &fields_ids_map_store, must_stop_processing, - progress: send_progress, + progress, }; let mut index_embeddings = index.embedding_configs(wtxn)?;