diff --git a/crates/nu_plugin_polars/src/dataframe/lazy/collect.rs b/crates/nu_plugin_polars/src/dataframe/lazy/collect.rs index c14098e28b..47f91f1d71 100644 --- a/crates/nu_plugin_polars/src/dataframe/lazy/collect.rs +++ b/crates/nu_plugin_polars/src/dataframe/lazy/collect.rs @@ -64,7 +64,9 @@ impl PluginCommand for LazyCollect { let value = input.into_value(call.head); match PolarsPluginObject::try_from_value(plugin, &value)? { PolarsPluginObject::NuLazyFrame(lazy) => { - let eager = lazy.collect(call.head)?; + let mut eager = lazy.collect(call.head)?; + // We don't want this converted back to a lazy frame + eager.from_lazy = true; Ok(PipelineData::Value( eager .cache(plugin, engine, call.head)? diff --git a/crates/nu_plugin_polars/src/dataframe/values/nu_lazyframe/mod.rs b/crates/nu_plugin_polars/src/dataframe/values/nu_lazyframe/mod.rs index bb2ae67130..86267dd51b 100644 --- a/crates/nu_plugin_polars/src/dataframe/values/nu_lazyframe/mod.rs +++ b/crates/nu_plugin_polars/src/dataframe/values/nu_lazyframe/mod.rs @@ -64,7 +64,7 @@ impl NuLazyFrame { help: None, inner: vec![], }) - .map(|df| NuDataFrame::new(false, df)) + .map(|df| NuDataFrame::new(true, df)) } pub fn apply_with_expr(self, expr: NuExpression, f: F) -> Self