Skip to content

Commit

Permalink
Use multithreaded runtime
Browse files Browse the repository at this point in the history
  • Loading branch information
Jay Chia committed Oct 31, 2023
1 parent 41cb632 commit 8f68e9c
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/daft-scan/src/glob.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@ fn run_glob(
io_config: Arc<daft_io::IOConfig>,
limit: Option<usize>,
) -> DaftResult<Vec<String>> {
// Use single-threaded runtime which should be safe here as it is not shared across async contexts
let runtime = get_runtime(false)?;
let io_client = get_io_client(false, io_config)?;
// Use multi-threaded runtime which should be global Arc-ed cached singletons
let runtime = get_runtime(true)?;
let io_client = get_io_client(true, io_config)?;

let _rt_guard = runtime.enter();
runtime.block_on(async {
Expand Down

0 comments on commit 8f68e9c

Please sign in to comment.