Test: enable shutdown tests and ignore those which fail

Signed-off-by: Anthony Griffon <anthony@griffon.one>
datafuselabs · Feb 21, 2024 · 90b3c5d · 90b3c5d
1 parent cc72453
commit 90b3c5d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/tests/tests/life_cycle/t11_shutdown.rs b/tests/tests/life_cycle/t11_shutdown.rs
@@ -1,4 +1,3 @@
-/*
 use std::sync::Arc;
 
 use anyhow::Result;
@@ -39,6 +38,7 @@ async fn shutdown() -> Result<()> {
 
 /// A panicked RaftCore should also return a proper error the next time accessing the `Raft`.
 #[async_entry::test(worker_threads = 8, init = "init_default_ut_tracing()", tracing_span = "debug")]
+#[cfg_attr(feature = "monoio", ignore)]
 async fn return_error_after_panic() -> Result<()> {
     let config = Arc::new(
         Config {
@@ -109,4 +109,3 @@ async fn return_error_after_shutdown() -> Result<()> {
 
     Ok(())
 }
-*/
diff --git a/tests/tests/membership/t12_concurrent_write_and_add_learner.rs b/tests/tests/membership/t12_concurrent_write_and_add_learner.rs
@@ -1,14 +1,16 @@
-/*
 use std::collections::BTreeSet;
 use std::sync::Arc;
 use std::time::Duration;
 
 use anyhow::Result;
 use maplit::btreeset;
+use openraft::AsyncRuntime;
 use openraft::Config;
 use openraft::LogIdOptionExt;
+use openraft::RaftTypeConfig;
 use openraft::ServerState;
 use openraft::Vote;
+use openraft_memstore::TypeConfig;
 
 use crate::fixtures::init_default_ut_tracing;
 use crate::fixtures::RaftRouter;
@@ -100,7 +102,7 @@ async fn concurrent_write_and_add_learner() -> Result<()> {
         let r = router.clone();
 
         let handle = {
-            tokio::spawn(
+            <TypeConfig as RaftTypeConfig>::AsyncRuntime::spawn(
                 async move {
                     r.add_learner(leader, 3).await.unwrap();
                     Ok::<(), anyhow::Error>(())
@@ -163,4 +165,3 @@ async fn wait_log(router: &RaftRouter, node_ids: &BTreeSet<u64>, want_log: u64)
 fn timeout() -> Option<Duration> {
     Some(Duration::from_millis(500))
 }
-*/