diff --git a/src/mito2/src/manifest/tests/checkpoint.rs b/src/mito2/src/manifest/tests/checkpoint.rs index 40dd369462..692f40422b 100644 --- a/src/mito2/src/manifest/tests/checkpoint.rs +++ b/src/mito2/src/manifest/tests/checkpoint.rs @@ -172,6 +172,11 @@ async fn test_corrupted_data_causing_checksum_error() { manager.update(nop_action()).await.unwrap(); } + // Wait for the checkpoint to finish. + while manager.checkpointer().is_doing_checkpoint() { + tokio::time::sleep(Duration::from_millis(50)).await; + } + // Check if there is a checkpoint assert!(manager .store()