Skip to content

Commit

Permalink
chore: change test_remove_outdated_meta_task sleep time to 40ms (#2620)
Browse files Browse the repository at this point in the history
chore: change test_remove_outdated_meta_task sleep time to 300ms
  • Loading branch information
WenyXu authored Oct 18, 2023
1 parent 46e106b commit d57b144
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/common/procedure/src/local.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down Expand Up @@ -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
Expand All @@ -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
Expand All @@ -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
Expand Down

0 comments on commit d57b144

Please sign in to comment.