snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-11-22 04:36:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Keep the smae naming behavior as before

Browse Source
This commit is contained in:
Kerollmops
2025-11-05 15:06:28 +01:00
parent 3ef1afc0f1
commit f9d57f54df
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/index-scheduler/src/scheduler/process_snapshot_creation.rs
View File

@@ -270,6 +270,11 @@ impl IndexScheduler {
let must_stop_processing = self.scheduler.must_stop_processing.clone();
let retry_backoff = backoff::ExponentialBackoff::default();
let db_name = {
let mut base_path = self.env.path().to_owned();
base_path.pop();
base_path.file_name().and_then(OsStr::to_str).unwrap_or("data.ms").to_string()
};
let (reader, writer) = std::io::pipe()?;
let uploader_task = tokio::spawn(async move {
@@ -284,8 +289,8 @@ impl IndexScheduler {
let bucket = Bucket::new(url, UrlStyle::Path, s3_bucket_name, s3_bucket_region)
.map_err(Error::S3BucketError)?;
let credential = Credentials::new(s3_access_key, s3_secret_key);
// TODO change this and use the database name like in the original version
let object_path = s3_snapshot_prefix.join("data.ms.snapshot");
// Note for the future: use with_added_extension, it's prettier
let object_path = s3_snapshot_prefix.join(format!("{db_name}.snapshot"));
let object = object_path.to_slash().expect("Invalid UTF-8 path").into_owned();
let action = bucket.create_multipart_upload(Some(&credential), &object);