From d57b144b2f7db9d9cbfeeea781cae2c5c714c658 Mon Sep 17 00:00:00 2001 From: Weny Xu Date: Wed, 18 Oct 2023 20:33:35 +0900 Subject: [PATCH] chore: change test_remove_outdated_meta_task sleep time to 40ms (#2620) chore: change test_remove_outdated_meta_task sleep time to 300ms --- src/common/procedure/src/local.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/common/procedure/src/local.rs b/src/common/procedure/src/local.rs index fda20cefde..a426632837 100644 --- a/src/common/procedure/src/local.rs +++ b/src/common/procedure/src/local.rs @@ -984,7 +984,7 @@ mod tests { .is_some()); } - #[tokio::test] + #[tokio::test(flavor = "multi_thread")] async fn test_remove_outdated_meta_task() { let dir = create_temp_dir("remove_outdated_meta_task"); let object_store = test_util::new_object_store(&dir); @@ -1013,7 +1013,7 @@ mod tests { watcher.changed().await.unwrap(); manager.start().await.unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(300)).await; assert!(manager .procedure_state(procedure_id) .await @@ -1036,7 +1036,7 @@ mod tests { .is_ok()); let mut watcher = manager.procedure_watcher(procedure_id).unwrap(); watcher.changed().await.unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(300)).await; assert!(manager .procedure_state(procedure_id) .await @@ -1058,7 +1058,7 @@ mod tests { watcher.changed().await.unwrap(); manager.start().await.unwrap(); - tokio::time::sleep(Duration::from_millis(10)).await; + tokio::time::sleep(Duration::from_millis(300)).await; assert!(manager .procedure_state(procedure_id) .await