change morsel.df to morsel.into_df

pola-rs · Oct 25, 2024 · a574188 · a574188
1 parent 33a7417
commit a574188
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/polars-stream/src/nodes/io_sinks/ipc.rs b/crates/polars-stream/src/nodes/io_sinks/ipc.rs
@@ -72,7 +72,7 @@ impl ComputeNode for IpcSinkNode {
 
         join_handles.push(scope.spawn_task(TaskPriority::High, async move {
             while let Ok(morsel) = receiver.recv().await {
-                self.writer.write_batch(morsel.df())?;
+                self.writer.write_batch(&morsel.into_df())?;
             }
 
             Ok(())