feat: IR Serde cross-filter (#21488)

pola-rs · Feb 27, 2025 · 828a1e7 · 828a1e7
1 parent bee578b
commit 828a1e7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/crates/polars-mem-engine/src/executors/scan/ipc.rs b/crates/polars-mem-engine/src/executors/scan/ipc.rs
@@ -41,7 +41,12 @@ impl IpcExec {
                 polars_io::pl_async::get_runtime().block_on_potential_spawn(self.read_async())?
             })
         } else {
-            self.read_sync()?
+            self.read_sync().map_err(|e| match &self.sources {
+                ScanSources::Paths(paths) => {
+                    e.context(format!("reading paths {:?} failed", paths.as_ref()).into())
+                },
+                _ => e,
+            })?
         };
 
         if self.file_options.rechunk {

diff --git a/crates/polars-plan/src/dsl/options.rs b/crates/polars-plan/src/dsl/options.rs
@@ -71,7 +71,7 @@ impl Default for StrptimeOptions {
 pub enum JoinTypeOptionsIR {
     #[cfg(feature = "iejoin")]
     IEJoin(IEJoinOptions),
-    #[cfg_attr(feature = "serde", serde(skip))]
+    #[cfg_attr(all(feature = "serde", not(feature = "ir_serde")), serde(skip))]
     // Fused cross join and filter (only in in-memory engine)
     Cross { predicate: ExprIR },
 }