From 34ee8dd2bd093c4fc70a945f6d60bfcd9ef65dc5 Mon Sep 17 00:00:00 2001 From: Alexander Falk Date: Wed, 19 Feb 2025 20:15:34 +0100 Subject: [PATCH] fix: remove unused code and added check if table exists in register_table Signed-off-by: Alexander Falk --- crates/core/src/data_catalog/storage/mod.rs | 15 +++------------ 1 file changed, 3 insertions(+), 12 deletions(-) diff --git a/crates/core/src/data_catalog/storage/mod.rs b/crates/core/src/data_catalog/storage/mod.rs index 40d95147c0..b888214d21 100644 --- a/crates/core/src/data_catalog/storage/mod.rs +++ b/crates/core/src/data_catalog/storage/mod.rs @@ -105,17 +105,6 @@ impl ListingSchemaProvider { let mut delta_table = delta_table.clone(); delta_table.load().await?; *table = Arc::from(delta_table); - //match delta_table.load().await { - // Ok(()) => { - // // Add the table back to the DashMap - // } - // Err(err) => { - // return Err(DataFusionError::Internal(format!( - // "Cannot load delta table. See stacktrace: {}", - // err.to_string() - // ))) - // } - //} } } } @@ -159,7 +148,9 @@ impl SchemaProvider for ListingSchemaProvider { name: String, table: Arc, ) -> datafusion_common::Result>> { - self.tables.insert(name, table.clone()); + if !self.table_exist(name.as_str()) { + self.tables.insert(name, table.clone()); + } Ok(Some(table)) }