Address review comments.

Cargo.lock

@@ -8353,6 +8353,7 @@ dependencies = [
  "tokio",
  "tracing",
  "tracing-subscriber",
+ "tracing-test",
  "windows 0.61.3",
 ]
 

common/client-core/surb-storage/src/lib.rs

@@ -56,10 +56,11 @@ where
 
         info!("PersistentReplyStorage is flushing all reply-related data to underlying storage");
         if let Err(err) = self.backend.flush_surb_storage(&mem_state).await {
-            error!("failed to flush our reply-related data to the persistent storage: {err}")
-        } else {
-            info!("Data flush is complete")
+            error!("failed to flush our reply-related data to the persistent storage: {err}");
+            self.backend.stop_storage_session().await.ok();
+            return;
         }
+        info!("Data flush is complete");
 
         if let Err(err) = self.backend.stop_storage_session().await {
             error!("failed to properly stop the storage session - {err}. We might not be able to smoothly restore it")

nym-sqlx-pool-guard/Cargo.toml

@@ -42,3 +42,4 @@ windows = { version = "0.61", features = [
 [dev-dependencies]
 tempfile.workspace = true
 tracing-subscriber.workspace = true
+tracing-test.workspace = true

nym-sqlx-pool-guard/src/lib.rs

@@ -180,6 +180,7 @@ mod tests {
         ConnectOptions, Executor,
         sqlite::{SqliteAutoVacuum, SqliteSynchronous},
     };
+    use tracing_test::traced_test;
 
     use super::*;
 
@@ -219,6 +220,7 @@ mod tests {
         tokio::fs::remove_file(database_path).await.unwrap();
     }
 
+    #[traced_test]
     #[tokio::test]
     async fn test_clone_drop_no_warning() {
         // Cloning the guard and dropping the clone should not warn because the original is still alive.
@@ -238,9 +240,11 @@ mod tests {
         {
             let _clone = guard.clone();
             assert_eq!(Arc::strong_count(&guard.inner), 2);
-            // _clone drops here - should NOT warn since guard still holds a reference
         }
         assert_eq!(Arc::strong_count(&guard.inner), 1);
+        assert!(!logs_contain(
+            "SqlitePoolGuard dropped without explicit close"
+        ));
 
         guard.close().await;
         tokio::fs::remove_file(database_path).await.unwrap();