fix ci

pola-rs · Nov 6, 2022 · 55069b2 · 55069b2
1 parent 00c2dbd
commit 55069b2
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/polars/polars-lazy/src/physical_plan/streaming/convert.rs b/polars/polars-lazy/src/physical_plan/streaming/convert.rs
@@ -63,7 +63,6 @@ fn streamable_join(join_type: &JoinType) -> bool {
     }
 }
 
-#[cfg(any(feature = "csv-file", feature = "parquet"))]
 pub(crate) fn insert_streaming_nodes(
     root: Node,
     lp_arena: &mut Arena<ALogicalPlan>,

diff --git a/polars/polars-lazy/src/physical_plan/streaming/mod.rs b/polars/polars-lazy/src/physical_plan/streaming/mod.rs
@@ -1,4 +1,3 @@
 mod convert;
 
-#[cfg(any(feature = "csv-file", feature = "parquet"))]
 pub(crate) use convert::insert_streaming_nodes;
diff --git a/py-polars/tests/unit/test_joins.py b/py-polars/tests/unit/test_joins.py
@@ -667,5 +667,6 @@ def test_streaming_joins() -> None:
             .collect(allow_streaming=True)
         )
 
+        # we cast to integer because pandas joins creates floats
         a = pl.from_pandas(pd_result).with_column(pl.all().cast(int)).sort(["a", "b"])
-        pl.testing.assert_frame_equal(a, pl_result)
+        pl.testing.assert_frame_equal(a, pl_result, check_dtype=False)