dependency update: update polar to 0.26.1 (#7743)

# Description

As title

# User-Facing Changes

# Tests + Formatting

Don't forget to add tests that cover your changes.

Make sure you've run and fixed any issues with these commands:

- `cargo fmt --all -- --check` to check standard code formatting (`cargo
fmt --all` applies these changes)
- `cargo clippy --workspace -- -D warnings -D clippy::unwrap_used -A
clippy::needless_collect` to check that you're using the standard code
style
- `cargo test --workspace` to check that all tests pass

# After Submitting

If your PR had any user-facing changes, update [the
documentation](https://github.com/nushell/nushell.github.io) after the
PR is merged, if necessary. This will help us keep the docs up to date.
This commit is contained in:
WindSoilder
2023-01-13 23:27:37 +08:00
committed by GitHub
parent 835bbb2e44
commit 3dd21c635a
9 changed files with 130 additions and 60 deletions

View File

@ -115,7 +115,7 @@ version = "3.0.0"
optional = true
[dependencies.polars]
version = "0.25.0"
version = "0.26.1"
optional = true
features = [
"arg_where",

View File

@ -185,22 +185,22 @@ fn command(
.cast(&DataType::Float64)
.ok()
.and_then(|ca| match ca.get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
});
let mean = match col.mean_as_series().get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
};
let median = match col.median_as_series().get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
};
let std = match col.std_as_series(0).get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
};
@ -209,7 +209,7 @@ fn command(
.cast(&DataType::Float64)
.ok()
.and_then(|ca| match ca.get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
});
@ -221,7 +221,7 @@ fn command(
.ok()
.and_then(|ca| ca.cast(&DataType::Float64).ok())
.and_then(|ca| match ca.get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
})
})
@ -232,7 +232,7 @@ fn command(
.cast(&DataType::Float64)
.ok()
.and_then(|ca| match ca.get(0) {
AnyValue::Float64(v) => Some(v),
Ok(AnyValue::Float64(v)) => Some(v),
_ => None,
});

View File

@ -5,7 +5,7 @@ use nu_protocol::{
engine::{Command, EngineState, Stack},
Category, Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Type, Value,
};
use polars::prelude::QuantileInterpolOptions;
use polars::prelude::{lit, QuantileInterpolOptions};
#[derive(Clone)]
pub struct ExprQuantile;
@ -72,7 +72,7 @@ impl Command for ExprQuantile {
let expr = NuExpression::try_from_value(value)?;
let expr: NuExpression = expr
.into_polars()
.quantile(quantile, QuantileInterpolOptions::default())
.quantile(lit(quantile), QuantileInterpolOptions::default())
.into();
Ok(PipelineData::Value(

View File

@ -5,7 +5,7 @@ use nu_protocol::{
engine::{Command, EngineState, Stack},
Category, Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Type, Value,
};
use polars::prelude::QuantileInterpolOptions;
use polars::prelude::{lit, QuantileInterpolOptions};
#[derive(Clone)]
pub struct LazyQuantile;
@ -60,7 +60,7 @@ impl Command for LazyQuantile {
let lazy = NuLazyFrame::new(
lazy.from_eager,
lazy.into_polars()
.quantile(quantile, QuantileInterpolOptions::default()),
.quantile(lit(quantile), QuantileInterpolOptions::default()),
);
Ok(PipelineData::Value(lazy.into_value(call.head)?, None))

View File

@ -79,7 +79,7 @@ fn command(
let res = if not_exact {
casted.as_date_not_exact(Some(format.as_str()))
} else {
casted.as_date(Some(format.as_str()))
casted.as_date(Some(format.as_str()), false)
};
let mut res = res

View File

@ -112,7 +112,7 @@ fn command(
let res = if not_exact {
casted.as_datetime_not_exact(Some(format.as_str()), TimeUnit::Milliseconds)
} else {
casted.as_datetime(Some(format.as_str()), TimeUnit::Milliseconds)
casted.as_datetime(Some(format.as_str()), TimeUnit::Milliseconds, false, false)
};
let mut res = res

View File

@ -35,7 +35,7 @@ impl Command for GetWeekDay {
result: Some(
NuDataFrame::try_from_columns(vec![Column::new(
"0".to_string(),
vec![Value::test_int(1), Value::test_int(1)],
vec![Value::test_int(2), Value::test_int(2)],
)])
.expect("simple df for test should not fail")
.into_value(Span::test_data()),

View File

@ -289,10 +289,7 @@ pub fn expr_to_value(expr: &Expr, span: Span) -> Value {
interpol,
} => {
let expr = expr_to_value(expr.as_ref(), span);
let quantile = Value::Float {
val: *quantile,
span,
};
let quantile = expr_to_value(quantile.as_ref(), span);
let interpol = Value::String {
val: format!("{:?}", interpol),
span,