From e117a5d09ffd8fc2b8675f710ae098dbe2e7e10b Mon Sep 17 00:00:00 2001 From: Zhengchao An Date: Sun, 16 Aug 2026 06:14:35 +0800 Subject: [PATCH] test(site-replication): preserve collapsed retry liability --- rustfs/src/admin/handlers/site_replication.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/rustfs/src/admin/handlers/site_replication.rs b/rustfs/src/admin/handlers/site_replication.rs index 2544ef302..b31c640de 100644 --- a/rustfs/src/admin/handlers/site_replication.rs +++ b/rustfs/src/admin/handlers/site_replication.rs @@ -14437,7 +14437,7 @@ mod tests { } #[test] - fn test_retry_event_dequeue_matches_deployment_id_or_endpoint() { + fn test_retry_event_dequeue_preserves_collapsed_path_across_peer_identity() { let peer = PeerInfo { deployment_id: "current-dep".to_string(), ..peer("remote", "https://remote.example.com") @@ -14462,9 +14462,8 @@ mod tests { let removed = dequeue_site_replication_retry_events(&mut queue, &peer, path); - assert_eq!(removed, 1); - assert_eq!(queue.len(), 1); - assert_eq!(queue[0].id, "different-path"); + assert_eq!(removed, 0); + assert_eq!(queue.len(), 2); } #[test]