From 58c210b38670053f9c4d2e35dc341fac89a49cbe Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Mon, 14 Sep 2026 15:39:11 +0800
Subject: [PATCH] test: isolate worker group WAL directories on Windows

Signed-off-by: evenyag <realevenyag@gmail.com>
---
 src/mito2/src/worker.rs | 21 ++++++++++++---------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/src/mito2/src/worker.rs b/src/mito2/src/worker.rs
index ed7ce4f592d..0483217f968 100644
--- a/src/mito2/src/worker.rs
+++ b/src/mito2/src/worker.rs
@@ -1628,9 +1628,16 @@ mod tests {
 
     #[tokio::test]
     async fn test_worker_group_start_stop() {
-        let env = TestEnv::with_prefix("group-stop").await;
-        let root = env.data_home().join("series_index");
-        for (run, enabled) in [false, true, false].into_iter().enumerate() {
+        for (enabled, existing_index) in [(false, false), (true, false), (false, true)] {
+            // Use a fresh WAL directory for each case: stopping workers does not stop the log store.
+            let env = TestEnv::with_prefix("group-stop").await;
+            let root = env.data_home().join("series_index");
+            if existing_index {
+                tokio::fs::create_dir_all(&root).await.unwrap();
+                tokio::fs::write(root.join("retained"), b"index")
+                    .await
+                    .unwrap();
+            }
             let group = env
                 .create_worker_group(MitoConfig {
                     num_workers: 4,
@@ -1643,12 +1650,8 @@ mod tests {
                 assert_eq!(worker.series_index_task_state.is_some(), enabled);
                 assert_eq!(worker.series_index_handle.lock().await.is_some(), enabled);
             }
-            assert_eq!(root.is_dir(), run > 0);
-            if enabled {
-                tokio::fs::write(root.join("retained"), b"index")
-                    .await
-                    .unwrap();
-            } else if root.exists() {
+            assert_eq!(root.is_dir(), enabled || existing_index);
+            if existing_index {
                 assert_eq!(
                     tokio::fs::read(root.join("retained")).await.unwrap(),
                     b"index"