From 5e8b5ca81f76e7c5c01cd53abb43f5ea289eca72 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=A9=AC=E7=99=BB=E5=B1=B1?= Date: Tue, 18 Aug 2026 10:13:19 +0800 Subject: [PATCH] style(ecstore): format recovery race tests --- crates/ecstore/src/cluster/rpc/remote_disk.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/crates/ecstore/src/cluster/rpc/remote_disk.rs b/crates/ecstore/src/cluster/rpc/remote_disk.rs index 3c7f354df..f36aa5b84 100644 --- a/crates/ecstore/src/cluster/rpc/remote_disk.rs +++ b/crates/ecstore/src/cluster/rpc/remote_disk.rs @@ -4848,7 +4848,10 @@ mod tests { }) .await .expect("teardown failure should re-arm recovery monitoring"); - assert!(disk.recovery_monitor_is_active(), "re-armed monitor should retain single-flight ownership"); + assert!( + disk.recovery_monitor_is_active(), + "re-armed monitor should retain single-flight ownership" + ); disk.cancel_token.cancel(); tokio::time::timeout(Duration::from_secs(2), async { @@ -6553,7 +6556,10 @@ mod tests { ) .await .expect("replacement remote disk should construct"); - assert_ne!(remote_disk.handle_id, replacement.handle_id, "replacement handles need distinct log identities"); + assert_ne!( + remote_disk.handle_id, replacement.handle_id, + "replacement handles need distinct log identities" + ); let span = tracing::info_span!("request-span", request_id = "req-remote-disk"); let _entered = span.enter();