Skip to content

Commit

Permalink
failing tests [skip ci]
Browse files Browse the repository at this point in the history
  • Loading branch information
ritchie46 committed Apr 17, 2024
1 parent df03f60 commit 7065ec8
Showing 1 changed file with 24 additions and 25 deletions.
49 changes: 24 additions & 25 deletions py-polars/src/lazyframe/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -938,58 +938,57 @@ impl PyLazyFrame {
ldf.fill_nan(fill_value.inner).into()
}

fn min(&self) -> PyResult<Self> {
fn min(&self) -> Self {
let ldf = self.ldf.clone();
let out = ldf.min().map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.min();
out.into()
}

fn max(&self) -> PyResult<Self> {
fn max(&self) -> Self {
let ldf = self.ldf.clone();
let out = ldf.max().map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.max();
out.into()
}

fn sum(&self) -> PyResult<Self> {
fn sum(&self) -> Self {
let ldf = self.ldf.clone();
let out = ldf.sum().map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.sum();
out.into()
}

fn mean(&self) -> PyResult<Self> {
fn mean(&self) -> Self {
let ldf = self.ldf.clone();
let out = ldf.mean().map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.mean();
out.into()
}

fn std(&self, ddof: u8) -> PyResult<Self> {
fn std(&self, ddof: u8) -> Self {
let ldf = self.ldf.clone();
let out = ldf.std(ddof).map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.std(ddof);
out.into()
}

fn var(&self, ddof: u8) -> PyResult<Self> {
fn var(&self, ddof: u8) -> Self {
let ldf = self.ldf.clone();
let out = ldf.var(ddof).map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.var(ddof);
out.into()
}

fn median(&self) -> PyResult<Self> {
fn median(&self) -> Self {
let ldf = self.ldf.clone();
let out = ldf.median().map_err(PyPolarsErr::from)?;
Ok(out.into())
let out = ldf.median();
out.into()
}

fn quantile(
&self,
quantile: PyExpr,
interpolation: Wrap<QuantileInterpolOptions>,
) -> PyResult<Self> {
) -> Self {
let ldf = self.ldf.clone();
let out = ldf
.quantile(quantile.inner, interpolation.0)
.map_err(PyPolarsErr::from)?;
Ok(out.into())
.quantile(quantile.inner, interpolation.0);
out.into()
}

fn explode(&self, column: Vec<PyExpr>) -> Self {
Expand Down

0 comments on commit 7065ec8

Please sign in to comment.