diff --git a/tests/env/src/lib.rs b/tests/env/src/lib.rs
index 41b76406..62887c1e 100644
--- a/tests/env/src/lib.rs
+++ b/tests/env/src/lib.rs
@@ -91,6 +91,7 @@ impl Node {
             .name(nd_tag.clone())
             .spawn(move || {
                 let runtime = tokio::runtime::Builder::new_multi_thread()
+                    .worker_threads(8)
                     .thread_name(nd_tag)
                     .enable_all()
                     .build()
diff --git a/tests/sorock-tests/tests/6_persistency.rs b/tests/sorock-tests/tests/6_persistency.rs
index cc7d0f6b..87259f30 100644
--- a/tests/sorock-tests/tests/6_persistency.rs
+++ b/tests/sorock-tests/tests/6_persistency.rs
@@ -36,7 +36,7 @@ async fn n3_restore() -> Result<()> {
     cluster.env().add_node(1);
     cluster.env().check_connectivity(1).await?;
     // Wait for election.
-    tokio::time::sleep(Duration::from_secs(30)).await;
+    tokio::time::sleep(Duration::from_secs(10)).await;
     assert_eq!(cluster.user(1).read(0).await?, cur_state);
 
     Ok(())