diff --git a/crates/milli/src/progress.rs b/crates/milli/src/progress.rs index 6a4231e91..8243ec235 100644 --- a/crates/milli/src/progress.rs +++ b/crates/milli/src/progress.rs @@ -138,6 +138,7 @@ macro_rules! make_atomic_progress { } make_atomic_progress!(Document alias AtomicDocumentStep => "document" ); +make_atomic_progress!(Payload alias AtomicPayloadStep => "payload" ); #[derive(Debug, Serialize, Clone)] pub struct ProgressView { diff --git a/crates/milli/src/update/new/indexer/document_operation.rs b/crates/milli/src/update/new/indexer/document_operation.rs index 4418944db..a1fc31f61 100644 --- a/crates/milli/src/update/new/indexer/document_operation.rs +++ b/crates/milli/src/update/new/indexer/document_operation.rs @@ -15,7 +15,7 @@ use super::super::document_change::DocumentChange; use super::document_changes::{DocumentChangeContext, DocumentChanges}; use super::retrieve_or_guess_primary_key; use crate::documents::PrimaryKey; -use crate::progress::{AtomicDocumentStep, Progress}; +use crate::progress::{AtomicDocumentStep, AtomicPayloadStep, Progress}; use crate::update::new::document::Versions; use crate::update::new::steps::IndexingStep; use crate::update::new::thread_local::MostlySend; @@ -71,7 +71,7 @@ impl<'pl> DocumentOperation<'pl> { let mut primary_key = None; let payload_count = operations.len(); - let (step, progress_step) = AtomicDocumentStep::new(payload_count as u32); + let (step, progress_step) = AtomicPayloadStep::new(payload_count as u32); progress.update_progress(progress_step); for (payload_index, operation) in operations.into_iter().enumerate() {