Skip to content

Commit 140eff1

Browse files
committed
Merge branch 'stack/native-761' into stack/native-759
2 parents 9009e45 + beb2a2f commit 140eff1

1 file changed

Lines changed: 14 additions & 2 deletions

File tree

  • data_plane/src/storage_engines/sketch_db/index

‎data_plane/src/storage_engines/sketch_db/index/mod.rs‎

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5349,7 +5349,6 @@ mod tests {
53495349
|| !persistence.manifest.live_parts().is_empty(),
53505350
Duration::from_secs(5)
53515351
));
5352-
let old_parts = persistence.manifest.live_parts().len();
53535352
store.remove_instance(old_sid).unwrap();
53545353
assert!(resolver
53555354
.resolve_with_reactivation("metric", "group", "family", |sid| store
@@ -5374,7 +5373,20 @@ mod tests {
53745373
);
53755374
}
53765375
assert!(wait_until(
5377-
|| persistence.manifest.live_parts().len() > old_parts,
5376+
|| {
5377+
// Old-series epochs may still publish after reactivation. Wait
5378+
// for this series, not an unrelated increase in part count.
5379+
persistence.manifest.live_parts().iter().any(|part| {
5380+
let path =
5381+
persistence::part::part_dir_path(&persistence.parts_root, part.part_id);
5382+
persistence::part::PartReader::open(&path).is_ok_and(|reader| {
5383+
reader
5384+
.index_records()
5385+
.iter()
5386+
.any(|row| row.agg_id == new_sid && row.start_ts < 90_000)
5387+
})
5388+
})
5389+
},
53785390
Duration::from_secs(5)
53795391
));
53805392
persistence.shutdown();

0 commit comments

Comments
 (0)