mirror of
https://github.com/meilisearch/MeiliSearch
synced 2025-07-15 13:58:36 +02:00
Fix errors being silently dropped
This commit is contained in:
parent
3f42f1a036
commit
aa09edb3fb
1 changed files with 4 additions and 1 deletions
|
@ -170,7 +170,7 @@ impl IndexScheduler {
|
||||||
let limit = payload_size.map(|ps| ps.as_u64() as usize).unwrap_or(20 * 1024 * 1024); // defaults to 20 MiB
|
let limit = payload_size.map(|ps| ps.as_u64() as usize).unwrap_or(20 * 1024 * 1024); // defaults to 20 MiB
|
||||||
let documents_url = format!("{base_url}/indexes/{uid}/documents");
|
let documents_url = format!("{base_url}/indexes/{uid}/documents");
|
||||||
|
|
||||||
request_threads()
|
let results = request_threads()
|
||||||
.broadcast(|ctx| {
|
.broadcast(|ctx| {
|
||||||
let index_rtxn = index
|
let index_rtxn = index
|
||||||
.read_txn()
|
.read_txn()
|
||||||
|
@ -297,6 +297,9 @@ impl IndexScheduler {
|
||||||
Some(uid.to_string()),
|
Some(uid.to_string()),
|
||||||
)
|
)
|
||||||
})?;
|
})?;
|
||||||
|
for result in results {
|
||||||
|
result?;
|
||||||
|
}
|
||||||
|
|
||||||
step.store(total_documents, atomic::Ordering::Relaxed);
|
step.store(total_documents, atomic::Ordering::Relaxed);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue