From 841e5ff1487f52cbbad468e167d586ceaed734a8 Mon Sep 17 00:00:00 2001 From: Simon Lin Date: Sun, 17 Nov 2024 20:17:39 +1100 Subject: [PATCH] c --- crates/polars-io/src/pl_async.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/polars-io/src/pl_async.rs b/crates/polars-io/src/pl_async.rs index 293d10cb3eea..08540ee09449 100644 --- a/crates/polars-io/src/pl_async.rs +++ b/crates/polars-io/src/pl_async.rs @@ -262,7 +262,7 @@ impl RuntimeManager { fn new() -> Self { let n_threads = std::env::var("POLARS_ASYNC_THREAD_COUNT") .map(|x| x.parse::().expect("integer")) - .unwrap_or((POOL.current_num_threads() / 4).clamp(1, 4)); + .unwrap_or(POOL.current_num_threads().clamp(1, 4)); if polars_core::config::verbose() { eprintln!("Async thread count: {}", n_threads);