|
32 | 32 |
|
33 | 33 | use datafusion::execution::runtime_env::RuntimeEnv; |
34 | 34 | use datafusion::prelude::*; |
35 | | -#[cfg(feature = "metadata-duckdb")] |
36 | 35 | use datafusion_ducklake::DuckdbMetadataProvider; |
37 | 36 | #[cfg(feature = "metadata-postgres")] |
38 | 37 | use datafusion_ducklake::PostgresMetadataProvider; |
@@ -78,21 +77,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> { |
78 | 77 | run_query(provider, snapshot_id, sql).await?; |
79 | 78 | } |
80 | 79 | } else { |
81 | | - #[cfg(not(feature = "metadata-duckdb"))] |
82 | | - { |
83 | | - eprintln!("Error: DuckDB support requires the 'metadata-duckdb' feature"); |
84 | | - eprintln!("Run with: cargo run --example basic_query --features metadata-duckdb"); |
85 | | - exit(1); |
86 | | - } |
87 | | - |
88 | | - #[cfg(feature = "metadata-duckdb")] |
89 | | - { |
90 | | - println!("Connecting to DuckDB catalog: {}", catalog_source); |
91 | | - let provider = Arc::new(DuckdbMetadataProvider::new(catalog_source)?); |
92 | | - let snapshot_id = provider.get_current_snapshot()?; |
93 | | - println!("Current snapshot ID: {}", snapshot_id); |
94 | | - run_query(provider, snapshot_id, sql).await?; |
95 | | - } |
| 80 | + println!("Connecting to DuckDB catalog: {}", catalog_source); |
| 81 | + let provider = Arc::new(DuckdbMetadataProvider::new(catalog_source)?); |
| 82 | + let snapshot_id = provider.get_current_snapshot()?; |
| 83 | + println!("Current snapshot ID: {}", snapshot_id); |
| 84 | + run_query(provider, snapshot_id, sql).await?; |
96 | 85 | } |
97 | 86 |
|
98 | 87 | Ok(()) |
|
0 commit comments