Skip to content

Commit

Permalink
Fix feature flags
Browse files Browse the repository at this point in the history
  • Loading branch information
stinodego committed Jul 15, 2024
1 parent 353559d commit 4c2eb12
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 2 additions & 0 deletions crates/polars-plan/src/plans/builder_dsl.rs
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
#[cfg(any(feature = "csv", feature = "ipc", feature = "parquet"))]
use std::path::PathBuf;
use std::sync::{Arc, Mutex, RwLock};

Expand Down Expand Up @@ -463,6 +464,7 @@ impl DslBuilder {
}

/// Initialize paths as non-expanded.
#[cfg(any(feature = "csv", feature = "ipc", feature = "parquet"))]
fn init_paths<P>(paths: P) -> Arc<Mutex<(Arc<[PathBuf]>, bool)>>
where
P: Into<Arc<[std::path::PathBuf]>>,
Expand Down
4 changes: 2 additions & 2 deletions crates/polars-plan/src/plans/conversion/dsl_to_ir.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
#[cfg(any(feature = "ipc", feature = "parquet"))]
use std::path::PathBuf;

use arrow::datatypes::ArrowSchemaRef;
Expand Down Expand Up @@ -711,6 +710,7 @@ pub fn to_alp_impl(
}

/// Expand scan paths if they were not already expanded.
#[allow(unused_variables)]
fn expand_scan_paths(
paths: Arc<Mutex<(Arc<[PathBuf]>, bool)>>,
scan_type: &mut FileScan,
Expand Down Expand Up @@ -738,7 +738,7 @@ fn expand_scan_paths(
} => expand_paths(&lock.0, file_options.glob, cloud_options.as_ref())?,
#[cfg(feature = "json")]
FileScan::NDJson { .. } => expand_paths(&lock.0, file_options.glob, None)?,
FileScan::Anonymous { .. } => unreachable!(), // Anonymous scans are already expanded.
FileScan::Anonymous { .. } => lock.0.clone(), // Anonymous scans are already expanded.
};

*lock = (paths_expanded, true);
Expand Down

0 comments on commit 4c2eb12

Please sign in to comment.