mirror of
https://github.com/meilisearch/MeiliSearch
synced 2025-02-11 21:13:32 +01:00
rename the atomic to something more meaningful
This commit is contained in:
parent
00eb47d42e
commit
84e2a1f836
@ -109,7 +109,7 @@ impl IndexScheduler {
|
|||||||
progress.update_progress(DumpCreationProgress::DumpTheBatches);
|
progress.update_progress(DumpCreationProgress::DumpTheBatches);
|
||||||
let mut dump_batches = dump.create_batches_queue()?;
|
let mut dump_batches = dump.create_batches_queue()?;
|
||||||
|
|
||||||
let (atomic, update_batch_progress) =
|
let (atomic_batch_progress, update_batch_progress) =
|
||||||
AtomicBatchStep::new(self.queue.batches.all_batches.len(&rtxn)? as u32);
|
AtomicBatchStep::new(self.queue.batches.all_batches.len(&rtxn)? as u32);
|
||||||
progress.update_progress(update_batch_progress);
|
progress.update_progress(update_batch_progress);
|
||||||
|
|
||||||
@ -134,7 +134,7 @@ impl IndexScheduler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
dump_batches.push_batch(&b)?;
|
dump_batches.push_batch(&b)?;
|
||||||
atomic.fetch_add(1, Ordering::Relaxed);
|
atomic_batch_progress.fetch_add(1, Ordering::Relaxed);
|
||||||
}
|
}
|
||||||
dump_batches.flush()?;
|
dump_batches.flush()?;
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user