mirror of
https://github.com/meilisearch/MeiliSearch
synced 2025-07-03 20:07:09 +02:00
Fix progress of into_changes
This commit is contained in:
parent
867138f166
commit
8380ddbdcd
11 changed files with 101 additions and 6 deletions
|
@ -1764,6 +1764,7 @@ pub(crate) mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)?;
|
||||
|
||||
if let Some(error) = operation_stats.into_iter().find_map(|stat| stat.error) {
|
||||
|
@ -1853,6 +1854,7 @@ pub(crate) mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)?;
|
||||
|
||||
if let Some(error) = operation_stats.into_iter().find_map(|stat| stat.error) {
|
||||
|
@ -1932,6 +1934,7 @@ pub(crate) mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
|
|
@ -65,7 +65,15 @@ pub fn setup_search_index_with_criteria(criteria: &[Criterion]) -> Index {
|
|||
|
||||
let indexer_alloc = Bump::new();
|
||||
let (document_changes, operation_stats, primary_key) = indexer
|
||||
.into_changes(&indexer_alloc, &index, &rtxn, None, &mut new_fields_ids_map, &|| false)
|
||||
.into_changes(
|
||||
&indexer_alloc,
|
||||
&index,
|
||||
&rtxn,
|
||||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
if let Some(error) = operation_stats.into_iter().find_map(|stat| stat.error) {
|
||||
|
|
|
@ -1947,6 +1947,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2130,6 +2131,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2190,6 +2192,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2241,6 +2244,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2291,6 +2295,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2343,6 +2348,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2400,6 +2406,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2450,6 +2457,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2500,6 +2508,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2692,6 +2701,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2749,6 +2759,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -2803,6 +2814,7 @@ mod tests {
|
|||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
|
|
@ -50,7 +50,15 @@ fn test_facet_distribution_with_no_facet_values() {
|
|||
|
||||
let indexer_alloc = Bump::new();
|
||||
let (document_changes, _operation_stats, primary_key) = indexer
|
||||
.into_changes(&indexer_alloc, &index, &rtxn, None, &mut new_fields_ids_map, &|| false)
|
||||
.into_changes(
|
||||
&indexer_alloc,
|
||||
&index,
|
||||
&rtxn,
|
||||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
indexer::index(
|
||||
|
|
|
@ -83,7 +83,15 @@ pub fn setup_search_index_with_criteria(criteria: &[Criterion]) -> Index {
|
|||
|
||||
let indexer_alloc = Bump::new();
|
||||
let (document_changes, operation_stats, primary_key) = indexer
|
||||
.into_changes(&indexer_alloc, &index, &rtxn, None, &mut new_fields_ids_map, &|| false)
|
||||
.into_changes(
|
||||
&indexer_alloc,
|
||||
&index,
|
||||
&rtxn,
|
||||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
if let Some(error) = operation_stats.into_iter().find_map(|stat| stat.error) {
|
||||
|
|
|
@ -319,7 +319,15 @@ fn criteria_ascdesc() {
|
|||
let payload = unsafe { memmap2::Mmap::map(&file).unwrap() };
|
||||
indexer.add_documents(&payload).unwrap();
|
||||
let (document_changes, _operation_stats, primary_key) = indexer
|
||||
.into_changes(&indexer_alloc, &index, &rtxn, None, &mut new_fields_ids_map, &|| false)
|
||||
.into_changes(
|
||||
&indexer_alloc,
|
||||
&index,
|
||||
&rtxn,
|
||||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
indexer::index(
|
||||
|
|
|
@ -128,7 +128,15 @@ fn test_typo_disabled_on_word() {
|
|||
|
||||
let indexer_alloc = Bump::new();
|
||||
let (document_changes, _operation_stats, primary_key) = indexer
|
||||
.into_changes(&indexer_alloc, &index, &rtxn, None, &mut new_fields_ids_map, &|| false)
|
||||
.into_changes(
|
||||
&indexer_alloc,
|
||||
&index,
|
||||
&rtxn,
|
||||
None,
|
||||
&mut new_fields_ids_map,
|
||||
&|| false,
|
||||
&|_progress| (),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
indexer::index(
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue