Skip to content

WIP Built some initial e2e datafusion infrastructure #107

WIP Built some initial e2e datafusion infrastructure

WIP Built some initial e2e datafusion infrastructure #107

Triggered via pull request January 31, 2025 01:06
Status Failure
Total duration 6m 10s
Artifacts

test.yml

on: pull_request
ubuntu / stable / minimal-versions
55s
ubuntu / stable / minimal-versions
ubuntu / stable / coverage
3m 7s
ubuntu / stable / coverage
Matrix: os-check
Matrix: required
Fit to window
Zoom out
Zoom in

Annotations

1 error and 50 warnings
ubuntu / stable / minimal-versions
Process completed with exit code 101.
[clippy] optd-datafusion/src/lib.rs#L9: optd-datafusion/src/lib.rs#L9
warning: unused import: `std::collections::HashMap` --> optd-datafusion/src/lib.rs:9:5 | 9 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(unused_imports)]` on by default
[clippy] optd-datafusion/src/lib.rs#L10: optd-datafusion/src/lib.rs#L10
warning: unused import: `Mutex` --> optd-datafusion/src/lib.rs:10:22 | 10 | use std::sync::{Arc, Mutex}; | ^^^^^
[clippy] optd-datafusion/src/lib.rs#L19: optd-datafusion/src/lib.rs#L19
warning: unused imports: `Explain`, `PlanType`, `TableSource`, and `ToStringifiedPlan` --> optd-datafusion/src/lib.rs:19:5 | 19 | Explain, LogicalPlan as DatafusionLogicalPlan, PlanType, TableSource, ToStringifiedPlan, | ^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L23: optd-datafusion/src/lib.rs#L23
warning: unused import: `log` --> optd-datafusion/src/lib.rs:23:27 | 23 | use datafusion::prelude::{log, Expr, SessionConfig, SessionContext}; | ^^^
[clippy] optd-datafusion/src/lib.rs#L26: optd-datafusion/src/lib.rs#L26
warning: unused import: `optd_core::operator::scalar::column_ref::ColumnRef` --> optd-datafusion/src/lib.rs:26:5 | 26 | use optd_core::operator::scalar::column_ref::ColumnRef; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L177: optd-datafusion/src/lib.rs#L177
warning: redundant field names in struct initialization --> optd-datafusion/src/lib.rs:177:22 | 177 | ScalarPlan { node: node } | ^^^^^^^^^^ help: replace it with: `node` | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#redundant_field_names = note: `#[warn(clippy::redundant_field_names)]` on by default
[clippy] optd-datafusion/src/lib.rs#L193: optd-datafusion/src/lib.rs#L193
warning: redundant field names in struct initialization --> optd-datafusion/src/lib.rs:193:23 | 193 | LogicalPlan { node: node } | ^^^^^^^^^^ help: replace it with: `node` | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#redundant_field_names
[clippy] optd-datafusion/src/lib.rs#L16: optd-datafusion/src/lib.rs#L16
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:16:41 | 16 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] optd-datafusion/src/lib.rs#L219: optd-datafusion/src/lib.rs#L219
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:219:23 | 219 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L234: optd-datafusion/src/lib.rs#L234
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:234:9 | 234 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L151: optd-datafusion/src/lib.rs#L151
warning: unused variable: `optdLogicalPlan` --> optd-datafusion/src/lib.rs:151:13 | 151 | let optdLogicalPlan = Self::conv_df_to_optd_relational(logical_plan); | ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optdLogicalPlan` | = note: `#[warn(unused_variables)]` on by default
[clippy] optd-datafusion/src/lib.rs#L152: optd-datafusion/src/lib.rs#L152
warning: unused variable: `optimizer` --> optd-datafusion/src/lib.rs:152:17 | 152 | let mut optimizer = self.optimizer.clone(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] optd-datafusion/src/lib.rs#L152: optd-datafusion/src/lib.rs#L152
warning: variable does not need to be mutable --> optd-datafusion/src/lib.rs:152:13 | 152 | let mut optimizer = self.optimizer.clone(); | ----^^^^^^^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] optd-datafusion/src/lib.rs#L177: optd-datafusion/src/lib.rs#L177
warning: unreachable expression --> optd-datafusion/src/lib.rs:177:9 | 170 | let node = match df_expr { | ____________________- 171 | | Expr::Column(column) => todo!(), 172 | | Expr::Literal(scalar_value) => todo!(), 173 | | Expr::BinaryExpr(binary_expr) => todo!(), 174 | | _ => panic!("OptD does not support this scalar expression"), 175 | | }; | |_________- any code following this `match` expression is unreachable, as all arms diverge 176 | 177 | ScalarPlan { node: node } | ^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression | = note: `#[warn(unreachable_code)]` on by default
[clippy] optd-datafusion/src/lib.rs#L170: optd-datafusion/src/lib.rs#L170
warning: unused variable: `node` --> optd-datafusion/src/lib.rs:170:13 | 170 | let node = match df_expr { | ^^^^ help: if this is intentional, prefix it with an underscore: `_node`
[clippy] optd-datafusion/src/lib.rs#L171: optd-datafusion/src/lib.rs#L171
warning: unused variable: `column` --> optd-datafusion/src/lib.rs:171:26 | 171 | Expr::Column(column) => todo!(), | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_column`
[clippy] optd-datafusion/src/lib.rs#L172: optd-datafusion/src/lib.rs#L172
warning: unused variable: `scalar_value` --> optd-datafusion/src/lib.rs:172:27 | 172 | Expr::Literal(scalar_value) => todo!(), | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_scalar_value`
[clippy] optd-datafusion/src/lib.rs#L173: optd-datafusion/src/lib.rs#L173
warning: unused variable: `binary_expr` --> optd-datafusion/src/lib.rs:173:30 | 173 | Expr::BinaryExpr(binary_expr) => todo!(), | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_binary_expr`
[clippy] optd-datafusion/src/lib.rs#L189: optd-datafusion/src/lib.rs#L189
warning: unused variable: `join` --> optd-datafusion/src/lib.rs:189:41 | 189 | DatafusionLogicalPlan::Join(join) => todo!(), | ^^^^ help: if this is intentional, prefix it with an underscore: `_join`
[clippy] optd-datafusion/src/lib.rs#L190: optd-datafusion/src/lib.rs#L190
warning: unused variable: `table_scan` --> optd-datafusion/src/lib.rs:190:46 | 190 | DatafusionLogicalPlan::TableScan(table_scan) => todo!(), | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_table_scan`
[clippy] optd-datafusion/src/lib.rs#L89: optd-datafusion/src/lib.rs#L89
warning: type `OptdOptimizer` is more private than the item `OptdQueryPlanner::optimizer` --> optd-datafusion/src/lib.rs:89:5 | 89 | pub optimizer: Arc<OptdOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `OptdQueryPlanner::optimizer` is reachable at visibility `pub` | note: but type `OptdOptimizer` is only usable at visibility `pub(crate)` --> optd-datafusion/src/lib.rs:39:1 | 39 | struct OptdOptimizer {} | ^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] optd-datafusion/src/lib.rs#L163: optd-datafusion/src/lib.rs#L163
warning: type `OptdOptimizer` is more private than the item `OptdQueryPlanner::new` --> optd-datafusion/src/lib.rs:163:5 | 163 | pub fn new(optimizer: OptdOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `OptdQueryPlanner::new` is reachable at visibility `pub` | note: but type `OptdOptimizer` is only usable at visibility `pub(crate)` --> optd-datafusion/src/lib.rs:39:1 | 39 | struct OptdOptimizer {} | ^^^^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L151: optd-datafusion/src/lib.rs#L151
warning: variable `optdLogicalPlan` should have a snake case name --> optd-datafusion/src/lib.rs:151:13 | 151 | let optdLogicalPlan = Self::conv_df_to_optd_relational(logical_plan); | ^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `optd_logical_plan` | = note: `#[warn(non_snake_case)]` on by default
[clippy] optd-datafusion/src/main.rs#L4: optd-datafusion/src/main.rs#L4
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/main.rs:4:41 | 4 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] optd-datafusion/src/main.rs#L15: optd-datafusion/src/main.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/main.rs:15:21 | 15 | let rt_config = RuntimeConfig::new(); | ^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L9: optd-datafusion/src/lib.rs#L9
warning: unused import: `std::collections::HashMap` --> optd-datafusion/src/lib.rs:9:5 | 9 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(unused_imports)]` on by default
[clippy] optd-datafusion/src/lib.rs#L10: optd-datafusion/src/lib.rs#L10
warning: unused import: `Mutex` --> optd-datafusion/src/lib.rs:10:22 | 10 | use std::sync::{Arc, Mutex}; | ^^^^^
[clippy] optd-datafusion/src/lib.rs#L19: optd-datafusion/src/lib.rs#L19
warning: unused imports: `Explain`, `PlanType`, `TableSource`, and `ToStringifiedPlan` --> optd-datafusion/src/lib.rs:19:5 | 19 | Explain, LogicalPlan as DatafusionLogicalPlan, PlanType, TableSource, ToStringifiedPlan, | ^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L23: optd-datafusion/src/lib.rs#L23
warning: unused import: `log` --> optd-datafusion/src/lib.rs:23:27 | 23 | use datafusion::prelude::{log, Expr, SessionConfig, SessionContext}; | ^^^
[clippy] optd-datafusion/src/lib.rs#L26: optd-datafusion/src/lib.rs#L26
warning: unused import: `optd_core::operator::scalar::column_ref::ColumnRef` --> optd-datafusion/src/lib.rs:26:5 | 26 | use optd_core::operator::scalar::column_ref::ColumnRef; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L177: optd-datafusion/src/lib.rs#L177
warning: redundant field names in struct initialization --> optd-datafusion/src/lib.rs:177:22 | 177 | ScalarPlan { node: node } | ^^^^^^^^^^ help: replace it with: `node` | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#redundant_field_names = note: `#[warn(clippy::redundant_field_names)]` on by default
[clippy] optd-datafusion/src/lib.rs#L193: optd-datafusion/src/lib.rs#L193
warning: redundant field names in struct initialization --> optd-datafusion/src/lib.rs:193:23 | 193 | LogicalPlan { node: node } | ^^^^^^^^^^ help: replace it with: `node` | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#redundant_field_names
[clippy] optd-datafusion/src/lib.rs#L16: optd-datafusion/src/lib.rs#L16
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:16:41 | 16 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] optd-datafusion/src/lib.rs#L219: optd-datafusion/src/lib.rs#L219
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:219:23 | 219 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L234: optd-datafusion/src/lib.rs#L234
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/lib.rs:234:9 | 234 | RuntimeConfig::new() | ^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L151: optd-datafusion/src/lib.rs#L151
warning: unused variable: `optdLogicalPlan` --> optd-datafusion/src/lib.rs:151:13 | 151 | let optdLogicalPlan = Self::conv_df_to_optd_relational(logical_plan); | ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optdLogicalPlan` | = note: `#[warn(unused_variables)]` on by default
[clippy] optd-datafusion/src/lib.rs#L152: optd-datafusion/src/lib.rs#L152
warning: unused variable: `optimizer` --> optd-datafusion/src/lib.rs:152:17 | 152 | let mut optimizer = self.optimizer.clone(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`
[clippy] optd-datafusion/src/lib.rs#L152: optd-datafusion/src/lib.rs#L152
warning: variable does not need to be mutable --> optd-datafusion/src/lib.rs:152:13 | 152 | let mut optimizer = self.optimizer.clone(); | ----^^^^^^^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default
[clippy] optd-datafusion/src/lib.rs#L177: optd-datafusion/src/lib.rs#L177
warning: unreachable expression --> optd-datafusion/src/lib.rs:177:9 | 170 | let node = match df_expr { | ____________________- 171 | | Expr::Column(column) => todo!(), 172 | | Expr::Literal(scalar_value) => todo!(), 173 | | Expr::BinaryExpr(binary_expr) => todo!(), 174 | | _ => panic!("OptD does not support this scalar expression"), 175 | | }; | |_________- any code following this `match` expression is unreachable, as all arms diverge 176 | 177 | ScalarPlan { node: node } | ^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression | = note: `#[warn(unreachable_code)]` on by default
[clippy] optd-datafusion/src/lib.rs#L170: optd-datafusion/src/lib.rs#L170
warning: unused variable: `node` --> optd-datafusion/src/lib.rs:170:13 | 170 | let node = match df_expr { | ^^^^ help: if this is intentional, prefix it with an underscore: `_node`
[clippy] optd-datafusion/src/lib.rs#L171: optd-datafusion/src/lib.rs#L171
warning: unused variable: `column` --> optd-datafusion/src/lib.rs:171:26 | 171 | Expr::Column(column) => todo!(), | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_column`
[clippy] optd-datafusion/src/lib.rs#L172: optd-datafusion/src/lib.rs#L172
warning: unused variable: `scalar_value` --> optd-datafusion/src/lib.rs:172:27 | 172 | Expr::Literal(scalar_value) => todo!(), | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_scalar_value`
[clippy] optd-datafusion/src/lib.rs#L173: optd-datafusion/src/lib.rs#L173
warning: unused variable: `binary_expr` --> optd-datafusion/src/lib.rs:173:30 | 173 | Expr::BinaryExpr(binary_expr) => todo!(), | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_binary_expr`
[clippy] optd-datafusion/src/lib.rs#L189: optd-datafusion/src/lib.rs#L189
warning: unused variable: `join` --> optd-datafusion/src/lib.rs:189:41 | 189 | DatafusionLogicalPlan::Join(join) => todo!(), | ^^^^ help: if this is intentional, prefix it with an underscore: `_join`
[clippy] optd-datafusion/src/lib.rs#L190: optd-datafusion/src/lib.rs#L190
warning: unused variable: `table_scan` --> optd-datafusion/src/lib.rs:190:46 | 190 | DatafusionLogicalPlan::TableScan(table_scan) => todo!(), | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_table_scan`
[clippy] optd-datafusion/src/lib.rs#L89: optd-datafusion/src/lib.rs#L89
warning: type `OptdOptimizer` is more private than the item `OptdQueryPlanner::optimizer` --> optd-datafusion/src/lib.rs:89:5 | 89 | pub optimizer: Arc<OptdOptimizer>, | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `OptdQueryPlanner::optimizer` is reachable at visibility `pub` | note: but type `OptdOptimizer` is only usable at visibility `pub(crate)` --> optd-datafusion/src/lib.rs:39:1 | 39 | struct OptdOptimizer {} | ^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default
[clippy] optd-datafusion/src/lib.rs#L163: optd-datafusion/src/lib.rs#L163
warning: type `OptdOptimizer` is more private than the item `OptdQueryPlanner::new` --> optd-datafusion/src/lib.rs:163:5 | 163 | pub fn new(optimizer: OptdOptimizer) -> Self { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function `OptdQueryPlanner::new` is reachable at visibility `pub` | note: but type `OptdOptimizer` is only usable at visibility `pub(crate)` --> optd-datafusion/src/lib.rs:39:1 | 39 | struct OptdOptimizer {} | ^^^^^^^^^^^^^^^^^^^^
[clippy] optd-datafusion/src/lib.rs#L151: optd-datafusion/src/lib.rs#L151
warning: variable `optdLogicalPlan` should have a snake case name --> optd-datafusion/src/lib.rs:151:13 | 151 | let optdLogicalPlan = Self::conv_df_to_optd_relational(logical_plan); | ^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `optd_logical_plan` | = note: `#[warn(non_snake_case)]` on by default
[clippy] optd-datafusion/src/main.rs#L4: optd-datafusion/src/main.rs#L4
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/main.rs:4:41 | 4 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default
[clippy] optd-datafusion/src/main.rs#L15: optd-datafusion/src/main.rs#L15
warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> optd-datafusion/src/main.rs:15:21 | 15 | let rt_config = RuntimeConfig::new(); | ^^^^^^^^^^^^^