diff --git a/polars/polars-core/src/series/implementations/object.rs b/polars/polars-core/src/series/implementations/object.rs index 09272495305c..10db26e2961c 100644 --- a/polars/polars-core/src/series/implementations/object.rs +++ b/polars/polars-core/src/series/implementations/object.rs @@ -10,6 +10,7 @@ use crate::frame::groupby::{GroupsProxy, IntoGroupsProxy}; use crate::prelude::*; use crate::series::implementations::SeriesWrap; use crate::series::private::{PrivateSeries, PrivateSeriesNumeric}; +#[cfg(feature = "chunked_ids")] use crate::series::IsSorted; impl PrivateSeriesNumeric for SeriesWrap> {} diff --git a/polars/polars-lazy/src/physical_plan/streaming/convert.rs b/polars/polars-lazy/src/physical_plan/streaming/convert.rs index f620da36884c..aae016e0ada4 100644 --- a/polars/polars-lazy/src/physical_plan/streaming/convert.rs +++ b/polars/polars-lazy/src/physical_plan/streaming/convert.rs @@ -357,15 +357,13 @@ pub(crate) fn insert_streaming_nodes( } } let input_schema = lp_arena.get(*input).schema(lp_arena); - #[allow(unused_mut)] - let mut can_stream = true; + #[allow(unused_variables)] + let options = options; #[cfg(feature = "dynamic_groupby")] - { - if options.rolling.is_some() || options.dynamic.is_some() { - can_stream = false - } - } + let can_stream = options.rolling.is_none() && options.dynamic.is_none(); + #[cfg(not(feature = "dynamic_groupby"))] + let can_stream = true; if can_stream && aggs.iter().all(|node| {