From ba5414743966f81b4704383e984876c8ab31d0a6 Mon Sep 17 00:00:00 2001 From: foskey51 Date: Sat, 15 Nov 2025 05:04:00 +0000 Subject: [PATCH] chore: enforce clippy lint needless_pass_by_value to datafusion-execution --- datafusion/execution/src/disk_manager.rs | 6 +++--- datafusion/execution/src/lib.rs | 3 +++ datafusion/execution/src/memory_pool/pool.rs | 8 ++++---- 3 files changed, 10 insertions(+), 7 deletions(-) diff --git a/datafusion/execution/src/disk_manager.rs b/datafusion/execution/src/disk_manager.rs index c2923d6112a6..5f741d3c78d1 100644 --- a/datafusion/execution/src/disk_manager.rs +++ b/datafusion/execution/src/disk_manager.rs @@ -79,7 +79,7 @@ impl DiskManagerBuilder { used_disk_space: Arc::new(AtomicU64::new(0)), }), DiskManagerMode::Directories(conf_dirs) => { - let local_dirs = create_local_dirs(conf_dirs)?; + let local_dirs = create_local_dirs(&conf_dirs)?; debug!( "Created local dirs {local_dirs:?} as DataFusion working directory" ); @@ -188,7 +188,7 @@ impl DiskManager { used_disk_space: Arc::new(AtomicU64::new(0)), })), DiskManagerConfig::NewSpecified(conf_dirs) => { - let local_dirs = create_local_dirs(conf_dirs)?; + let local_dirs = create_local_dirs(&conf_dirs)?; debug!( "Created local dirs {local_dirs:?} as DataFusion working directory" ); @@ -408,7 +408,7 @@ impl Drop for RefCountedTempFile { } /// Setup local dirs by creating one new dir in each of the given dirs -fn create_local_dirs(local_dirs: Vec) -> Result>> { +fn create_local_dirs(local_dirs: &[PathBuf]) -> Result>> { local_dirs .iter() .map(|root| { diff --git a/datafusion/execution/src/lib.rs b/datafusion/execution/src/lib.rs index 55243e301e0e..9439aefc008d 100644 --- a/datafusion/execution/src/lib.rs +++ b/datafusion/execution/src/lib.rs @@ -23,6 +23,9 @@ // Make sure fast / cheap clones on Arc are explicit: // https://github.com/apache/datafusion/issues/11143 #![deny(clippy::clone_on_ref_ptr)] +// https://github.com/apache/datafusion/issues/18503 +#![deny(clippy::needless_pass_by_value)] +#![cfg_attr(test, allow(clippy::needless_pass_by_value))] //! DataFusion execution configuration and runtime structures diff --git a/datafusion/execution/src/memory_pool/pool.rs b/datafusion/execution/src/memory_pool/pool.rs index d6b55182aa6b..135a55275bb2 100644 --- a/datafusion/execution/src/memory_pool/pool.rs +++ b/datafusion/execution/src/memory_pool/pool.rs @@ -466,8 +466,8 @@ impl MemoryPool for TrackConsumersPool { DataFusionError::ResourcesExhausted( provide_top_memory_consumers_to_error_msg( &reservation.consumer().name, - e, - self.report_top(self.top.into()), + &e, + &self.report_top(self.top.into()), ), ) } @@ -494,8 +494,8 @@ impl MemoryPool for TrackConsumersPool { fn provide_top_memory_consumers_to_error_msg( consumer_name: &str, - error_msg: String, - top_consumers: String, + error_msg: &str, + top_consumers: &str, ) -> String { format!("Additional allocation failed for {consumer_name} with top memory consumers (across reservations) as:\n{top_consumers}\nError: {error_msg}") }