snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-09-06 20:56:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5683 from meilisearch/fix-recoverable-file-store-error

Browse Source 
Make sure to recover from missing update file
This commit is contained in:
Many the fish
2025-07-01 09:08:55 +00:00
committed by GitHub
parent 0ef52941c7 0d85f8fcee
commit 7dfb2071b5
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/index-scheduler/src/scheduler/create_batch.rs
View File

@ -1,4 +1,5 @@
use std::fmt; use std::fmt;
use std::io::ErrorKind;
use meilisearch_types::heed::RoTxn; use meilisearch_types::heed::RoTxn;
use meilisearch_types::milli::update::IndexDocumentsMethod; use meilisearch_types::milli::update::IndexDocumentsMethod;
@ -577,7 +578,11 @@ impl IndexScheduler {
.and_then(|task| task.ok_or(Error::CorruptedTaskQueue))?; .and_then(|task| task.ok_or(Error::CorruptedTaskQueue))?;
if let Some(uuid) = task.content_uuid() { if let Some(uuid) = task.content_uuid() {
let content_size = self.queue.file_store.compute_size(uuid)?; let content_size = match self.queue.file_store.compute_size(uuid) {
Ok(content_size) => content_size,
Err(file_store::Error::IoError(err)) if err.kind() == ErrorKind::NotFound => 0,
Err(otherwise) => return Err(otherwise.into()),
};
total_size = total_size.saturating_add(content_size); total_size = total_size.saturating_add(content_size);
} }