Fix

krinart · krinart · commit 0a1cc2141f78 · 2026-03-13T14:48:57.000-07:00
diff --git a/crates/etl/src/lib.rs b/crates/etl/src/lib.rs
@@ -1791,7 +1791,6 @@ async fn run_pipeline(
                         }
                     };
 
-                let source_rows: usize = source_batches.iter().map(|b| b.num_rows()).sum();
                 if source_batches.is_empty() {
                     debug!(
                         table = %table_name,

Original file line number	Diff line number	Diff line change
`@@ -1791,7 +1791,6 @@ async fn run_pipeline(`
`1791`	`1791`	`}`
`1792`	`1792`	`};`
`1793`	`1793`
`1794`		`- let source_rows: usize = source_batches.iter().map(\|b\| b.num_rows()).sum();`
`1795`	`1794`	`if source_batches.is_empty() {`
`1796`	`1795`	`debug!(`
`1797`	`1796`	`table = %table_name,`