Merge branch 'main' into fix-integration-dagster

delta-io · Sep 17, 2024 · 33d5d10 · 33d5d10
2 parents 531a824 + 73107a7
commit 33d5d10
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/crates/core/src/storage/mod.rs b/crates/core/src/storage/mod.rs
@@ -49,16 +49,20 @@ fn io_rt(config: Option<&RuntimeConfig>) -> &Runtime {
                 } else {
                     RuntimeBuilder::new_current_thread()
                 };
-                let builder = builder.worker_threads(config.worker_threads);
-                let builder = if config.enable_io && config.enable_time {
+                let mut builder = builder.worker_threads(config.worker_threads);
+                let mut builder = if config.enable_io && config.enable_time {
                     builder.enable_all()
-                } else if config.enable_io && !config.enable_time {
-                    builder.enable_io()
                 } else if !config.enable_io && config.enable_time {
                     builder.enable_time()
                 } else {
                     builder
                 };
+                #[cfg(unix)]
+                {
+                    if config.enable_io && !config.enable_time {
+                        builder = builder.enable_io();
+                    }
+                }
                 builder
                     .thread_name(
                         config