From df4aac17c02042252ff361fc7f353e6296f13364 Mon Sep 17 00:00:00 2001 From: Andy Grove Date: Mon, 3 Jun 2024 11:50:06 -0600 Subject: [PATCH] lint --- core/src/execution/datafusion/planner.rs | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs index 20119b13a..cc31f98c3 100644 --- a/core/src/execution/datafusion/planner.rs +++ b/core/src/execution/datafusion/planner.rs @@ -833,14 +833,13 @@ impl PhysicalPlanner { } // Consumes the first input source for the scan - let input_source = if self.exec_context_id == TEST_EXEC_CONTEXT_ID - && inputs.is_empty() - { - // For unit test, we will set input batch to scan directly by `set_input_batch`. - None - } else { - Some(inputs.remove(0)) - }; + let input_source = + if self.exec_context_id == TEST_EXEC_CONTEXT_ID && inputs.is_empty() { + // For unit test, we will set input batch to scan directly by `set_input_batch`. + None + } else { + Some(inputs.remove(0)) + }; // The `ScanExec` operator will take actual arrays from Spark during execution let scan = ScanExec::new(self.exec_context_id, input_source, fields)?;