diff --git a/parquet/src/arrow/async_reader/store.rs b/parquet/src/arrow/async_reader/store.rs index d47ca744d8f6..73cb129bf5e9 100644 --- a/parquet/src/arrow/async_reader/store.rs +++ b/parquet/src/arrow/async_reader/store.rs @@ -148,7 +148,8 @@ impl ParquetObjectReader { O: Send + 'static, E: Into + Send + 'static, { - match &self.runtime { + let handle = self.runtime.clone().or_else(|| Handle::try_current().ok()); + match handle { Some(handle) => { let path = self.path.clone(); let store = Arc::clone(&self.store);