From fc9b5be7684612ef52b5d35f0c1804c74307a334 Mon Sep 17 00:00:00 2001 From: Sammy Sidhu Date: Wed, 14 Feb 2024 11:21:07 -0800 Subject: [PATCH] drop non case is acc ready --- src/daft-scan/src/scan_task_iters.rs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/daft-scan/src/scan_task_iters.rs b/src/daft-scan/src/scan_task_iters.rs index 081aa7a292..fe3d470a2f 100644 --- a/src/daft-scan/src/scan_task_iters.rs +++ b/src/daft-scan/src/scan_task_iters.rs @@ -47,9 +47,7 @@ struct MergeByFileSize { impl MergeByFileSize { fn accumulator_ready(&self) -> bool { - if self.accumulator.is_none() { - true - } else if let Some(acc) = &self.accumulator && let Some(acc_bytes) = acc.size_bytes() && acc_bytes >= self.min_size_bytes { + if let Some(acc) = &self.accumulator && let Some(acc_bytes) = acc.size_bytes() && acc_bytes >= self.min_size_bytes { true } else { false