From 607a0b9bb0b2169c50dda4d00aa055f821c385ea Mon Sep 17 00:00:00 2001 From: Hauser Date: Wed, 30 Sep 2026 13:46:07 +0800 Subject: [PATCH] test(heal): replay fixtures with source incarnation Co-Authored-By: heihutu Co-Authored-By: zhi22915 --- crates/heal/src/heal/mrf_queue/partial_write.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/heal/src/heal/mrf_queue/partial_write.rs b/crates/heal/src/heal/mrf_queue/partial_write.rs index 1c001e9f9..e1286ac96 100644 --- a/crates/heal/src/heal/mrf_queue/partial_write.rs +++ b/crates/heal/src/heal/mrf_queue/partial_write.rs @@ -999,7 +999,7 @@ mod tests { let replacement = intent("legacy"); writes - .admit(replacement, 1, 8192) + .admit_with_source_incarnation(replacement, Some(incarnation), 1, 8192) .expect("a new generation should become retryable"); writes.mark_persisted(); assert_eq!(writes.unverified_legacy_count(), 0); @@ -1007,7 +1007,7 @@ mod tests { let mut restarted = PartialWrites::default(); restarted - .admit(original, 1, 8192) + .admit_with_source_incarnation(original, Some(incarnation), 1, 8192) .expect("the unchanged journal re-arms the same responsibility after restart"); restarted.mark_persisted(); assert_eq!(restarted.unverified_legacy_count(), 0); @@ -1043,7 +1043,7 @@ mod tests { .expect("hold state checkpoint"); let mut restored = PartialWrites::default(); restored - .admit(original, 1, 8192) + .admit_with_source_incarnation(original, Some(incarnation), 1, 8192) .expect("replay journal intent before applying lifecycle state"); assert!(restored.restore_state(&intent("legacy-lifecycle"), &checkpoint)); restored.mark_persisted(); @@ -1126,7 +1126,7 @@ mod tests { let mut restored = PartialWrites::default(); restored - .admit(original.clone(), 1, 8192) + .admit_with_source_incarnation(original.clone(), Some(original_incarnation), 1, 8192) .expect("replay creates retry index entry"); assert!(restored.restore_state(&original, &checkpoint)); let (previous, _) = restored