From 0f58facd27d1e2574b2faeb0aef3bed7c38d2b24 Mon Sep 17 00:00:00 2001
From: Weston Pace <weston.pace@gmail.com>
Date: Wed, 27 Nov 2024 15:05:02 -0800
Subject: [PATCH] Address clippy suggestions

---
 datafusion/core/src/execution/context/mod.rs   | 16 ++++++++--------
 datafusion/core/src/execution/session_state.rs |  2 +-
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/datafusion/core/src/execution/context/mod.rs b/datafusion/core/src/execution/context/mod.rs
index 81cb8feed843..b90706ce8017 100644
--- a/datafusion/core/src/execution/context/mod.rs
+++ b/datafusion/core/src/execution/context/mod.rs
@@ -917,7 +917,7 @@ impl SessionContext {
                 let (name, catalog_list) = {
                     let state = self.state.read();
                     let name = state.config().options().catalog.default_catalog.clone();
-                    let catalog_list = state.catalog_list().clone();
+                    let catalog_list = Arc::clone(state.catalog_list());
                     (name, catalog_list)
                 };
                 let catalog_fut = catalog_list.catalog(&name);
@@ -962,7 +962,7 @@ impl SessionContext {
             (true, Some(_)) => self.return_empty_dataframe(),
             (true, None) | (false, None) => {
                 let new_catalog = Arc::new(MemoryCatalogProvider::new());
-                let catalog_list = self.state.write().catalog_list().clone();
+                let catalog_list = Arc::clone(self.state.write().catalog_list());
                 catalog_list
                     .register_catalog(catalog_name, new_catalog)
                     .await?;
@@ -1016,7 +1016,7 @@ impl SessionContext {
                         state.config_options().catalog.default_catalog.to_string()
                     }
                 };
-                let catalog_list = state.catalog_list().clone();
+                let catalog_list = Arc::clone(state.catalog_list());
                 (catalog_name, catalog_list)
             };
             if let Some(catalog) = catalog_list.catalog(&catalog_name).await? {
@@ -1084,7 +1084,7 @@ impl SessionContext {
             let (resolved, catalog_list) = {
                 let state = self.state.read();
                 let resolved = state.resolve_table_ref(table_ref);
-                let catalog_list = state.catalog_list().clone();
+                let catalog_list = Arc::clone(state.catalog_list());
                 (resolved, catalog_list)
             };
             if let Some(catalog) = catalog_list.catalog(&resolved.catalog).await? {
@@ -1444,20 +1444,20 @@ impl SessionContext {
         catalog: Arc<dyn CatalogProvider>,
     ) -> Result<Option<Arc<dyn CatalogProvider>>> {
         let name = name.into();
-        let catalog_list = self.state.read().catalog_list().clone();
+        let catalog_list = Arc::clone(self.state.read().catalog_list());
         catalog_list.register_catalog(name, catalog).await
     }
 
     /// Retrieves the list of available catalog names.
     pub async fn catalog_names(&self) -> BoxStream<'static, Result<String>> {
-        let catalog_list = self.state.read().catalog_list().clone();
+        let catalog_list = Arc::clone(self.state.read().catalog_list());
         catalog_list.catalog_names().await
     }
 
     /// Retrieves a [`CatalogProvider`] instance by name
     pub async fn catalog(&self, name: &str) -> Result<Option<Arc<dyn CatalogProvider>>> {
-        let catalog_list = self.state.read().catalog_list().clone();
-        Ok(catalog_list.catalog(name).await?)
+        let catalog_list = Arc::clone(self.state.read().catalog_list());
+        catalog_list.catalog(name).await
     }
 
     /// Registers a [`TableProvider`] as a table that can be
diff --git a/datafusion/core/src/execution/session_state.rs b/datafusion/core/src/execution/session_state.rs
index fe6fd43d7691..2d5a807bf25a 100644
--- a/datafusion/core/src/execution/session_state.rs
+++ b/datafusion/core/src/execution/session_state.rs
@@ -308,7 +308,7 @@ impl SessionState {
         table_ref: impl Into<TableReference>,
     ) -> BoxFuture<'static, datafusion_common::Result<Arc<dyn SchemaProvider>>> {
         let resolved_ref = self.resolve_table_ref(table_ref);
-        let catalog_list = self.catalog_list.clone();
+        let catalog_list = Arc::clone(&self.catalog_list);
         if self.config.information_schema() && *resolved_ref.schema == *INFORMATION_SCHEMA
         {
             return std::future::ready(Ok(Arc::new(InformationSchemaProvider::new(