diff --git a/crates/polars-stream/src/physical_plan/lower_ir.rs b/crates/polars-stream/src/physical_plan/lower_ir.rs index ea6d44362a0b..d522c87ca96c 100644 --- a/crates/polars-stream/src/physical_plan/lower_ir.rs +++ b/crates/polars-stream/src/physical_plan/lower_ir.rs @@ -23,7 +23,7 @@ pub fn lower_ir( let schema = columns.clone(); let input = lower_ir(*input, ir_arena, expr_arena, phys_sm)?; Ok(phys_sm.insert(PhysNode::SimpleProjection { input, schema })) - } + }, // TODO: split partially streamable selections to avoid fallback as much as possible. IR::Select {