(a few build warning fixes)

pola-rs · Mar 27, 2023 · c548a05 · c548a05
1 parent 8e01e4e
commit c548a05
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git 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<T: PolarsObject> PrivateSeriesNumeric for SeriesWrap<ObjectChunked<T>> {}

diff --git 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| {