fix ordering of merge

Eventual-Inc · Dec 4, 2023 · fa91d2e · fa91d2e
1 parent 378280a
commit fa91d2e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/daft-scan/src/scan_task_iters.rs b/src/daft-scan/src/scan_task_iters.rs
@@ -67,13 +67,13 @@ impl Iterator for MergeByFileSize {
                 match (should_merge, should_yield_merged_result) {
                     // Merge and yield the merged result immediately
                     (true, true) => Some(Ok(Arc::new(
-                        ScanTask::merge(child_item.as_ref(), accumulator.as_ref())
+                        ScanTask::merge(accumulator.as_ref(), child_item.as_ref())
                             .expect("ScanTasks should be mergeable in MergeByFileSize"),
                     ))),
                     // Merge and continue iterating and accumulating without yielding a result right now
                     (true, false) => {
                         self.accumulator = Some(Arc::new(
-                            ScanTask::merge(child_item.as_ref(), accumulator.as_ref())
+                            ScanTask::merge(accumulator.as_ref(), child_item.as_ref())
                                 .expect("ScanTasks should be mergeable in MergeByFileSize"),
                         ));
                         self.next()