diff --git a/crates/heal/src/heal/manager/tests/root_recovery.rs b/crates/heal/src/heal/manager/tests/root_recovery.rs index 7702a89d2..669893b1a 100644 --- a/crates/heal/src/heal/manager/tests/root_recovery.rs +++ b/crates/heal/src/heal/manager/tests/root_recovery.rs @@ -1873,8 +1873,10 @@ async fn root_recovery_legacy_cluster_requires_a_fresh_generation_bound_task() { let restarted = recovery_manager(vec![disk]); restarted.replay_root_heals().await.expect("replay legacy root record"); - let queued = restarted.heal_queue.lock().await.requests().cloned().collect::>(); - assert!(queued.is_empty(), "unfenced legacy work must not bind to a later bucket generation"); + assert!( + restarted.heal_queue.lock().await.requests().next().is_none(), + "unfenced legacy work must not bind to a later bucket generation" + ); assert!( restarted .root_recovery