rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-10-12 15:02:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: use root-relative metadata snapshot keys

Browse Source 
Signed-off-by: jeremyhi <fengjiachun@gmail.com>
This commit is contained in:
jeremyhi
2026-09-23 09:06:28 +08:00
parent f643e1257b
commit 0d899870ed
1 changed files with 12 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common/meta/src/snapshot.rs
+12 -28
View File
@@ -407,8 +407,7 @@ mod tests {
#[tokio::test]
async fn test_dump_and_restore() {
common_telemetry::init_default_ut_logging();
let (temp_dir, kv_backend, manager) = test_env("test_dump_and_restore");
let temp_path = temp_dir.path();
let (_temp_dir, kv_backend, manager) = test_env("test_dump_and_restore");
for i in 0..10 {
kv_backend
@@ -420,32 +419,20 @@ mod tests {
.await
.unwrap();
}
let dump_path = temp_path.join("snapshot");
manager
.dump(&format!(
"{}/metadata_snapshot",
&dump_path.as_path().display().to_string()
))
.await
.unwrap();
manager.dump("snapshot/metadata_snapshot").await.unwrap();
// Clean up the kv backend
kv_backend.clear();
let err = manager
.dump(&format!(
"{}/metadata_snapshot.metadata.fb",
&dump_path.as_path().display().to_string()
))
.dump("snapshot/metadata_snapshot.metadata.fb")
.await
.unwrap_err();
assert_matches!(err, Error::Unexpected { .. });
assert!(err.to_string().contains("already exists"));
let restore_path = dump_path
.join("metadata_snapshot.metadata.fb")
.as_path()
.display()
.to_string();
manager.restore(&restore_path).await.unwrap();
manager
.restore("snapshot/metadata_snapshot.metadata.fb")
.await
.unwrap();
for i in 0..10 {
let key = format!("test_{}", i);
@@ -456,14 +443,11 @@ mod tests {
#[tokio::test]
async fn test_restore_from_nonexistent_file() {
let (temp_dir, _kv_backend, manager) = test_env("test_restore_from_nonexistent_file");
let restore_path = temp_dir
.path()
.join("nonexistent.metadata.fb")
.as_path()
.display()
.to_string();
let err = manager.restore(&restore_path).await.unwrap_err();
let (_temp_dir, _kv_backend, manager) = test_env("test_restore_from_nonexistent_file");
let err = manager
.restore("nonexistent.metadata.fb")
.await
.unwrap_err();
assert_matches!(err, Error::ReadObject { .. })
}
}