Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 7 additions & 5 deletions .github/workflows/build.yml
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ jobs:
- uses: actions/checkout@v6

- name: Setup Rust
uses: dtolnay/rust-toolchain@4be7066ada62dd38de10e7b70166bc74ed198c30
uses: dtolnay/rust-toolchain@4cda84d5c5c54efe2404f9d843567869ab1699d4
with:
toolchain: "nightly"
components: rustfmt
Expand Down Expand Up @@ -152,7 +152,7 @@ jobs:
path: .

- name: Setup Rust
uses: dtolnay/rust-toolchain@29eef336d9b2848a0b548edc03f92a220660cdb8
uses: dtolnay/rust-toolchain@4cda84d5c5c54efe2404f9d843567869ab1699d4

- name: Cache Cargo
uses: Swatinem/rust-cache@v2
Expand Down Expand Up @@ -231,7 +231,7 @@ jobs:
path: .

- name: Setup Rust
uses: dtolnay/rust-toolchain@29eef336d9b2848a0b548edc03f92a220660cdb8
uses: dtolnay/rust-toolchain@4cda84d5c5c54efe2404f9d843567869ab1699d4

- name: Cache Cargo
uses: Swatinem/rust-cache@v2
Expand Down Expand Up @@ -286,7 +286,8 @@ jobs:
steps:
- uses: actions/checkout@v6

- uses: dtolnay/rust-toolchain@29eef336d9b2848a0b548edc03f92a220660cdb8
- name: Setup Rust
uses: dtolnay/rust-toolchain@4cda84d5c5c54efe2404f9d843567869ab1699d4

- run: rm LICENSE.txt
- name: Download LICENSE.txt
Expand Down Expand Up @@ -368,7 +369,8 @@ jobs:
steps:
- uses: actions/checkout@v6

- uses: dtolnay/rust-toolchain@29eef336d9b2848a0b548edc03f92a220660cdb8
- name: Setup Rust
uses: dtolnay/rust-toolchain@4cda84d5c5c54efe2404f9d843567869ab1699d4

- run: rm LICENSE.txt
- name: Download LICENSE.txt
Expand Down
4 changes: 2 additions & 2 deletions crates/core/src/expr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -433,7 +433,7 @@ impl PyExpr {
Expr::Literal(scalar_value, _) => scalar_to_pyarrow(scalar_value, py),
_ => Err(py_type_err(format!(
"Non Expr::Literal encountered in types: {:?}",
&self.expr
self.expr
))),
}
}
Expand Down Expand Up @@ -612,7 +612,7 @@ impl PyExpr {
_ => {
return Err(py_type_err(format!(
"Catch all triggered in get_operator_name: {:?}",
&self.expr
self.expr
)));
}
})
Expand Down
4 changes: 2 additions & 2 deletions crates/core/src/expr/aggregate.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,8 +65,8 @@ impl Display for PyAggregate {
\nAggregates(s): {:?}
\nInput: {:?}
\nProjected Schema: {:?}",
&self.aggregate.group_expr,
&self.aggregate.aggr_expr,
self.aggregate.group_expr,
self.aggregate.aggr_expr,
self.aggregate.input,
self.aggregate.schema
)
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/alias.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ impl Display for PyAlias {
"Alias
\nExpr: `{:?}`
\nAlias Name: `{}`",
&self.alias.expr, &self.alias.name
self.alias.expr, self.alias.name
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/between.rs
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ impl Display for PyBetween {
Negated: {:?}
Low: {:?}
High: {:?}",
&self.between.expr, &self.between.negated, &self.between.low, &self.between.high
self.between.expr, self.between.negated, self.between.low, self.between.high
)
}
}
Expand Down
20 changes: 10 additions & 10 deletions crates/core/src/expr/bool_expr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ impl Display for PyNot {
f,
"Not
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -82,7 +82,7 @@ impl Display for PyIsNotNull {
f,
"IsNotNull
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -118,7 +118,7 @@ impl Display for PyIsNull {
f,
"IsNull
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -154,7 +154,7 @@ impl Display for PyIsTrue {
f,
"IsTrue
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -190,7 +190,7 @@ impl Display for PyIsFalse {
f,
"IsFalse
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -226,7 +226,7 @@ impl Display for PyIsUnknown {
f,
"IsUnknown
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -262,7 +262,7 @@ impl Display for PyIsNotTrue {
f,
"IsNotTrue
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -298,7 +298,7 @@ impl Display for PyIsNotFalse {
f,
"IsNotFalse
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -334,7 +334,7 @@ impl Display for PyIsNotUnknown {
f,
"IsNotUnknown
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down Expand Up @@ -370,7 +370,7 @@ impl Display for PyNegative {
f,
"Negative
Expr: {}",
&self.expr
self.expr
)
}
}
Expand Down
5 changes: 1 addition & 4 deletions crates/core/src/expr/create_memory_table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,10 +57,7 @@ impl Display for PyCreateMemoryTable {
Input: {:?}
if_not_exists: {:?}
or_replace: {:?}",
&self.create.name,
&self.create.input,
&self.create.if_not_exists,
&self.create.or_replace,
self.create.name, self.create.input, self.create.if_not_exists, self.create.or_replace,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/create_view.rs
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ impl Display for PyCreateView {
input: {:?}
or_replace: {:?}
definition: {:?}",
&self.create.name, &self.create.input, &self.create.or_replace, &self.create.definition,
self.create.name, self.create.input, self.create.or_replace, self.create.definition,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/drop_table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ impl Display for PyDropTable {
name: {:?}
if_exists: {:?}
schema: {:?}",
&self.drop.name, &self.drop.if_exists, &self.drop.schema,
self.drop.name, self.drop.if_exists, self.drop.schema,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/empty_relation.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ impl Display for PyEmptyRelation {
"Empty Relation
Produce One Row: {:?}
Schema: {:?}",
&self.empty.produce_one_row, &self.empty.schema
self.empty.produce_one_row, self.empty.schema
)
}
}
Expand Down
10 changes: 5 additions & 5 deletions crates/core/src/expr/explain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -61,11 +61,11 @@ impl Display for PyExplain {
stringified_plans: {:?}
schema: {:?}
logical_optimization_succeeded: {:?}",
&self.explain.verbose,
&self.explain.plan,
&self.explain.stringified_plans,
&self.explain.schema,
&self.explain.logical_optimization_succeeded
self.explain.verbose,
self.explain.plan,
self.explain.stringified_plans,
self.explain.schema,
self.explain.logical_optimization_succeeded
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/filter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ impl Display for PyFilter {
"Filter
Predicate: {:?}
Input: {:?}",
&self.filter.predicate, &self.filter.input
self.filter.predicate, self.filter.input
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/higher_order_function.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ impl Display for PyHigherOrderFunction {
f,
"HigherOrderFunction(name={}, args={:?})",
self.higher_order.name(),
&self.higher_order.args,
self.higher_order.args,
)
}
}
Expand Down
16 changes: 8 additions & 8 deletions crates/core/src/expr/join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -132,14 +132,14 @@ impl Display for PyJoin {
JoinConstraint: {:?}
Schema: {:?}
NullEquality: {:?}",
&self.join.left,
&self.join.right,
&self.join.on,
&self.join.filter,
&self.join.join_type,
&self.join.join_constraint,
&self.join.schema,
&self.join.null_equality,
self.join.left,
self.join.right,
self.join.on,
self.join.filter,
self.join.join_type,
self.join.join_constraint,
self.join.schema,
self.join.null_equality,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/lambda.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ impl Display for PyLambda {
write!(
f,
"Lambda(params={:?}, body={:?})",
&self.lambda.params, &self.lambda.body,
self.lambda.params, self.lambda.body,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/lambda_variable.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ impl From<PyLambdaVariable> for LambdaVariable {

impl Display for PyLambdaVariable {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
write!(f, "LambdaVariable({})", &self.variable.name)
write!(f, "LambdaVariable({})", self.variable.name)
}
}

Expand Down
24 changes: 12 additions & 12 deletions crates/core/src/expr/like.rs
Original file line number Diff line number Diff line change
Expand Up @@ -55,10 +55,10 @@ impl Display for PyLike {
Expr: {:?}
Pattern: {:?}
Escape_Char: {:?}",
&self.negated(),
&self.expr(),
&self.pattern(),
&self.escape_char()
self.negated(),
self.expr(),
self.pattern(),
self.escape_char()
)
}
}
Expand Down Expand Up @@ -119,10 +119,10 @@ impl Display for PyILike {
Expr: {:?}
Pattern: {:?}
Escape_Char: {:?}",
&self.negated(),
&self.expr(),
&self.pattern(),
&self.escape_char()
self.negated(),
self.expr(),
self.pattern(),
self.escape_char()
)
}
}
Expand Down Expand Up @@ -183,10 +183,10 @@ impl Display for PySimilarTo {
Expr: {:?}
Pattern: {:?}
Escape_Char: {:?}",
&self.negated(),
&self.expr(),
&self.pattern(),
&self.escape_char()
self.negated(),
self.expr(),
self.pattern(),
self.escape_char()
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/limit.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ impl Display for PyLimit {
Skip: {:?}
Fetch: {:?}
Input: {:?}",
&self.limit.skip, &self.limit.fetch, &self.limit.input
self.limit.skip, self.limit.fetch, self.limit.input
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/projection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ impl Display for PyProjection {
\nExpr(s): {:?}
\nInput: {:?}
\nProjected Schema: {:?}",
&self.projection.expr, &self.projection.input, &self.projection.schema,
self.projection.expr, self.projection.input, self.projection.schema,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/repartition.rs
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ impl Display for PyRepartition {
"Repartition
input: {:?}
partitioning_scheme: {:?}",
&self.repartition.input, &self.repartition.partitioning_scheme,
self.repartition.input, self.repartition.partitioning_scheme,
)
}
}
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/sort.rs
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ impl Display for PySort {
\nExpr(s): {:?}
\nInput: {:?}
\nSchema: {:?}",
&self.sort.expr,
self.sort.expr,
self.sort.input,
self.sort.input.schema()
)
Expand Down
2 changes: 1 addition & 1 deletion crates/core/src/expr/sort_expr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ impl Display for PySortExpr {
Expr: {:?}
Asc: {:?}
NullsFirst: {:?}",
&self.sort.expr, &self.sort.asc, &self.sort.nulls_first
self.sort.expr, self.sort.asc, self.sort.nulls_first
)
}
}
Expand Down
Loading
Loading