Process completed with exit code 101.

The job was canceled because "stable" failed.

The operation was canceled.

Process completed with exit code 1.

Process completed with exit code 101.

Process completed with exit code 1.

warning: unused import: `self` --> optd-core/src/optimizer/handlers.rs:11:17 | 11 | group::{self, GroupId}, | ^^^^ | = note: `#[warn(unused_imports)]` on by default

warning: unused variable: `plan` --> optd-core/src/optimizer/handlers.rs:130:9 | 130 | plan: PartialPhysicalPlan, | ^^^^ help: if this is intentional, prefix it with an underscore: `_plan` | = note: `#[warn(unused_variables)]` on by default

warning: unused variable: `goal` --> optd-core/src/optimizer/handlers.rs:131:9 | 131 | goal: Goal, | ^^^^ help: if this is intentional, prefix it with an underscore: `_goal`

warning: unused variable: `expr` --> optd-core/src/optimizer/handlers.rs:139:9 | 139 | expr: OptimizedExpression, | ^^^^ help: if this is intentional, prefix it with an underscore: `_expr`

warning: unused variable: `goal` --> optd-core/src/optimizer/handlers.rs:140:9 | 140 | goal: Goal, | ^^^^ help: if this is intentional, prefix it with an underscore: `_goal`

warning: type `engine::error::EngineError` is more private than the item `error::Error::Engine::0` --> optd-core/src/error.rs:7:12 | 7 | Engine(EngineError), | ^^^^^^^^^^^ field `error::Error::Engine::0` is reachable at visibility `pub` | note: but type `engine::error::EngineError` is only usable at visibility `pub(crate)` --> optd-core/src/engine/error.rs:9:1 | 9 | pub(crate) enum EngineError { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default

warning: function `value_to_partial_logical` is never used --> optd-core/src/bridge/into_cir.rs:22:15 | 22 | pub(crate) fn value_to_partial_logical(value: &Value) -> PartialLogicalPlan { | ^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default

warning: function `value_to_partial_physical` is never used --> optd-core/src/bridge/into_cir.rs:41:15 | 41 | pub(crate) fn value_to_partial_physical(value: &Value) -> PartialPhysicalPlan { | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `value_to_cost` is never used --> optd-core/src/bridge/into_cir.rs:58:15 | 58 | pub(crate) fn value_to_cost(value: &Value) -> Cost { | ^^^^^^^^^^^^^

warning: function `value_to_logical_properties` is never used --> optd-core/src/bridge/into_cir.rs:66:15 | 66 | pub(crate) fn value_to_logical_properties(properties_value: &Value) -> LogicalProperties { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `RuleResult` is never used --> optd-core/src/engine/mod.rs:44:6 | 44 | type RuleResult<T> = Result<T, Error>; | ^^^^^^^^^^

warning: struct `Engine` is never constructed --> optd-core/src/engine/mod.rs:48:19 | 48 | pub(crate) struct Engine<E: Expander> { | ^^^^^^

warning: multiple associated items are never used --> optd-core/src/engine/mod.rs:57:19 | 55 | impl<E: Expander> Engine<E> { | --------------------------- associated items in this implementation 56 | /// Creates a new engine with the given context and expander. 57 | pub(crate) fn new(context: Context, expander: E) -> Self { | ^^^ ... 71 | pub(crate) fn with_context(self, context: Context) -> Self { | ^^^^^^^^^^^^ ... 89 | pub(crate) fn match_and_apply_logical_rule( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 114 | pub(crate) fn match_and_apply_implementation_rule( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 142 | pub(crate) fn cost_plan(self, plan: &PartialPhysicalPlan) -> CostStream { | ^^^^^^^^^ ... 164 | pub(crate) async fn derive_properties( | ^^^^^^^^^^^^^^^^^ ... 190 | fn create_rule_call(&self, rule_name: &str, args: Vec<Value>) -> Arc<Expr> { | ^^^^^^^^^^^^^^^^ ... 205 | fn process_rule_result<T, F>(result: Result<Value, Error>, transform: F) -> RuleResult<T> | ^^^^^^^^^^^^^^^^^^^

warning: variants `Fail` and `NoResult` are never constructed --> optd-core/src/engine/error.rs:11:5 | 9 | pub(crate) enum EngineError { | ----------- variants in this enum 10 | /// A failure triggered by a Fail expression in the HIR. 11 | Fail(String), | ^^^^ 12 | /// A failure triggered by the failure of returning any result. 13 | NoResult, | ^^^^^^^^ | = note: `EngineError` has derived impls for the traits `Debug` and `Clone`, but these are intentionally ignored during dead code analysis

warning: trait `Evaluate` is never used --> optd-core/src/engine/eval/mod.rs:36:18 | 36 | pub(crate) trait Evaluate { | ^^^^^^^^

warning: function `evaluate_core_expr` is never used --> optd-core/src/engine/eval/core.rs:30:15 | 30 | pub(super) fn evaluate_core_expr<E>(data: CoreData<Arc<Expr>>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^

warning: function `evaluate_collection` is never used --> optd-core/src/engine/eval/core.rs:49:4 | 49 | fn evaluate_collection<E>( | ^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_map` is never used --> optd-core/src/engine/eval/core.rs:70:4 | 70 | fn evaluate_map<E>(items: Vec<(Arc<Expr>, Arc<Expr>)>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^

warning: function `evaluate_fail` is never used --> optd-core/src/engine/eval/core.rs:101:4 | 101 | fn evaluate_fail<E>(msg: Arc<Expr>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^

warning: function `evaluate_pattern_match` is never used --> optd-core/src/engine/eval/expr.rs:76:4 | 76 | fn evaluate_pattern_match<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_if_then_else` is never used --> optd-core/src/engine/eval/expr.rs:101:4 | 101 | fn evaluate_if_then_else<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_let_binding` is never used --> optd-core/src/engine/eval/expr.rs:137:4 | 137 | fn evaluate_let_binding<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_binary_expr` is never used --> optd-core/src/engine/eval/expr.rs:165:4 | 165 | fn evaluate_binary_expr<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_unary_expr` is never used --> optd-core/src/engine/eval/expr.rs:189:4 | 189 | fn evaluate_unary_expr<E>(op: UnaryOp, expr: Arc<Expr>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_function_call` is never used --> optd-core/src/engine/eval/expr.rs:202:4 | 202 | fn evaluate_function_call<E>(fun: Arc<Expr>, args: Vec<Arc<Expr>>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_closure_call` is never used --> optd-core/src/engine/eval/expr.rs:233:4 | 233 | fn evaluate_closure_call<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_rust_udf_call` is never used --> optd-core/src/engine/eval/expr.rs:263:4 | 263 | fn evaluate_rust_udf_call<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_reference` is never used --> optd-core/src/engine/eval/expr.rs:279:4 | 279 | fn evaluate_reference<E>(ident: String, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^

warning: type alias `MatchResult` is never used --> optd-core/src/engine/eval/match.rs:26:17 | 26 | pub(crate) type MatchResult = (Value, Option<Context>); | ^^^^^^^^^^^

warning: function `try_match_arms` is never used --> optd-core/src/engine/eval/match.rs:32:15 | 32 | pub(super) fn try_match_arms<E>( | ^^^^^^^^^^^^^^

warning: function `match_pattern` is never used --> optd-core/src/engine/eval/match.rs:79:4 | 79 | fn match_pattern<E>(value: Value, pattern: Pattern, engine: Engine<E>) -> MatchResultStream | ^^^^^^^^^^^^^

warning: function `match_pattern_combinations` is never used --> optd-core/src/engine/eval/match.rs:164:4 | 164 | fn match_pattern_combinations<E, I>(pairs: I, engine: Engine<E>) -> VecMatchResultStream | ^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `match_array_pattern` is never used --> optd-core/src/engine/eval/match.rs:176:4 | 176 | fn match_array_pattern<E>( | ^^^^^^^^^^^^^^^^^^^

warning: function `match_struct_pattern` is never used --> optd-core/src/engine/eval/match.rs:234:4 | 234 | fn match_struct_pattern<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `match_operator_pattern` is never used --> optd-core/src/engine/eval/match.rs:284:4 | 284 | fn match_operator_pattern<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `match_against_expanded_values` is never used --> optd-core/src/engine/eval/match.rs:373:4 | 373 | fn match_against_expanded_values<E, S>( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `OperatorStream` is never used --> optd-core/src/engine/eval/operator.rs:31:6 | 31 | type OperatorStream = Pin<Box<dyn Stream<Item = Result<Operator<Value>, Error>> + Send>>; | ^^^^^^^^^^^^^^

warning: function `evaluate_logical_operator` is never used --> optd-core/src/engine/eval/operator.rs:38:15 | 38 | pub(super) fn evaluate_logical_operator<E>( | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_physical_operator` is never used --> optd-core/src/engine/eval/operator.rs:56:15 | 56 | pub(super) fn evaluate_physical_operator<E>( | ^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `explore_operator_data` is never used --> optd-core/src/engine/eval/operator.rs:78:4 | 78 | fn explore_operator_data<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `explore_children` is never used --> optd-core/src/engine/eval/operator.rs:100:4 | 100 | fn explore_children<E>( | ^^^^^^^^^^^^^^^^

warning: methods `expand_all_exprs`, `expand_optimized_expr`, and `retrieve_properties` are never used --> optd-core/src/engine/expander.rs:13:8 | 9 | pub trait Expander: Clone + Send + Sync + 'static { | -------- methods in this trait ... 13 | fn expand_all_exprs(&self, group_id: GroupId) -> ValueStream; | ^^^^^^^^^^^^^^^^ ... 19 | fn expand_optimized_expr(&self, physical_goal: &Goal) -> ValueStream; | ^^^^^^^^^^^^^^^^^^^^^ ... 24 | async fn retrieve_properties(&self, group_id: GroupId) -> Value; | ^^^^^^^^^^^^^^^^^^^

warning: type alias `VecValueStream` is never used --> optd-core/src/engine/utils/streams.rs:29:17 | 29 | pub(crate) type VecValueStream = Pin<Box<dyn Stream<Item = Result<Vec<Value>, Error>> + Send>>; | ^^^^^^^^^^^^^^

warning: type alias `PartialLogicalPlanStream` is never used --> optd-core/src/engine/utils/streams.rs:35:17 | 35 | pub(crate) type PartialLogicalPlanStream = | ^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `PartialPhysicalPlanStream` is never used --> optd-core/src/engine/utils/streams.rs:42:17 | 42 | pub(crate) type PartialPhysicalPlanStream = | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `MatchResultStream` is never used --> optd-core/src/engine/utils/streams.rs:46:17 | 46 | pub(crate) type MatchResultStream = Pin<Box<dyn Stream<Item = Result<MatchResult, Error>> + Send>>; | ^^^^^^^^^^^^^^^^^

warning: type alias `VecMatchResultStream` is never used --> optd-core/src/engine/utils/streams.rs:49:17 | 49 | pub(crate) type VecMatchResultStream = | ^^^^^^^^^^^^^^^^^^^^

warning: type alias `CostStream` is never used --> optd-core/src/engine/utils/streams.rs:53:17 | 53 | pub(crate) type CostStream = Pin<Box<dyn Stream<Item = Result<Cost, Error>> + Send>>; | ^^^^^^^^^^

warning: function `process_items_in_sequence` is never used --> optd-core/src/engine/utils/streams.rs:74:15 | 74 | pub(crate) fn process_items_in_sequence<E, I, T, F>( | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_all_combinations` is never used --> optd-core/src/engine/utils/streams.rs:147:15 | 147 | pub(crate) fn evaluate_all_combinations<E, I>(items: I, engine: Engine<E>) -> VecValueStream | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `propagate_error` is never used --> optd-core/src/engine/utils/streams.rs:166:15 | 166 | pub(crate) fn propagate_error<T>(e: Error) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> | ^^^^^^^^^^^^^^^

warning: function `propagate_success` is never used --> optd-core/src/engine/utils/streams.rs:183:15 | 183 | pub(crate) fn propagate_success<T>(value: T) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> | ^^^^^^^^^^^^^^^^^

warning: function `stream_from_result` is never used --> optd-core/src/engine/utils/streams.rs:208:15 | 208 | pub(crate) fn stream_from_result<'a, T, U, F, Fut>( | ^^^^^^^^^^^^^^^^^^

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:91:20 | 91 | SubscribeGroup(GroupId, Sender<LogicalExpression>), | -------------- ^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 91 | SubscribeGroup((), ()), | ~~ ~~

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:97:19 | 97 | SubscribeGoal(Goal, Sender<OptimizedExpression>), | ------------- ^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 97 | SubscribeGoal((), ()), | ~~ ~~

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:102:24 | 102 | RetrieveProperties(GroupId, oneshot::Sender<LogicalProperties>), | ------------------ ^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 102 | RetrieveProperties((), ()), | ~~ ~~

warning: variants `OptimizeRequest`, `EgestOptimized`, `NewLogicalPartial`, `NewPhysicalPartial`, `NewOptimizedExpression`, and `CreateGroup` are never constructed --> optd-core/src/optimizer/mod.rs:60:5 | 55 | enum OptimizerMessage { | ---------------- variants in this enum ... 60 | OptimizeRequest(OptimizeRequest), | ^^^^^^^^^^^^^^^ ... 67 | EgestOptimized(OptimizedExpression, Sender<PhysicalPlan>), | ^^^^^^^^^^^^^^ ... 70 | NewLogicalPartial(PartialLogicalPlan, GroupId), | ^^^^^^^^^^^^^^^^^ ... 75 | NewPhysicalPartial(PartialPhysicalPlan, Goal), | ^^^^^^^^^^^^^^^^^^ ... 80 | NewOptimizedExpression(OptimizedExpression, Goal), | ^^^^^^^^^^^^^^^^^^^^^^ ... 86 | CreateGroup(LogicalProperties, LogicalExpression, i64), | ^^^^^^^^^^^ | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis

warning: struct `PendingMessage` is never constructed --> optd-core/src/optimizer/mod.rs:110:8 | 110 | struct PendingMessage { | ^^^^^^^^^^^^^^

warning: struct `Optimizer` is never constructed --> optd-core/src/optimizer/mod.rs:127:8 | 127 | struct Optimizer<M: Memoize> { | ^^^^^^^^^

warning: associated items `launch` and `run` are never used --> optd-core/src/optimizer/mod.rs:199:12 | 194 | impl<M: Memoize> Optimizer<M> { | ----------------------------- associated items in this implementation ... 199 | pub fn launch(memo: M, hir: HIR) -> Sender<OptimizeRequest> { | ^^^^^^ ... 254 | async fn run(mut self) { | ^^^

warning: methods `egest_best_plan` and `egest_child_plan` are never used --> optd-core/src/optimizer/egest.rs:30:25 | 16 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 30 | pub(super) async fn egest_best_plan( | ^^^^^^^^^^^^^^^ ... 69 | async fn egest_child_plan( | ^^^^^^^^^^^^^^^^

warning: multiple methods are never used --> optd-core/src/optimizer/handlers.rs:28:25 | 25 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 28 | pub(super) async fn process_optimize_request( | ^^^^^^^^^^^^^^^^^^^^^^^^ ... 72 | pub(super) async fn process_egest_optimized( | ^^^^^^^^^^^^^^^^^^^^^^^ ... 93 | pub(super) async fn process_new_logical_partial( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 128 | pub(super) async fn process_new_physical_partial( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 137 | pub(super) async fn process_new_optimized_expression( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 147 | pub(super) async fn process_create_group( | ^^^^^^^^^^^^^^^^^^^^ ... 163 | pub(super) async fn process_group_subscription( | ^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 174 | pub(super) async fn process_goal_subscription( | ^^^^^^^^^^^^^^^^^^^^^^^^^ ... 185 | pub(super) async fn process_retrieve_properties( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 208 | async fn handle_merge_result(&mut self, result: MergeResult) { | ^^^^^^^^^^^^^^^^^^^ ... 289 | async fn resolve_dependencies(&mut self, completed_job_id: i64) { | ^^^^^^^^^^^^^^^^^^^^

warning: enum `LogicalIngest` is never used --> optd-core/src/optimizer/ingest.rs:19:17 | 19 | pub(super) enum LogicalIngest { | ^^^^^^^^^^^^^

warning: enum `InternalLogicalIngest` is never used --> optd-core/src/optimizer/ingest.rs:30:6 | 30 | enum InternalLogicalIngest { | ^^^^^^^^^^^^^^^^^^^^^

warning: multiple methods are never used --> optd-core/src/optimizer/ingest.rs:45:25 | 35 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 45 | pub(super) async fn try_ingest_logical( | ^^^^^^^^^^^^^^^^^^ ... 99 | async fn ingest_logical_plan( | ^^^^^^^^^^^^^^^^^^^ ... 125 | async fn ingest_physical_plan( | ^^^^^^^^^^^^^^^^^^^^ ... 153 | async fn ingest_logical_operator( | ^^^^^^^^^^^^^^^^^^^^^^^ ... 231 | async fn ingest_physical_operator( | ^^^^^^^^^^^^^^^^^^^^^^^^ ... 266 | async fn process_logical_child( | ^^^^^^^^^^^^^^^^^^^^^ ... 293 | async fn process_physical_child( | ^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `MemoizeResult` is never used --> optd-core/src/optimizer/memo.rs:11:17 | 11 | pub(crate) type MemoizeResult<T> = Result<T, Error>; | ^^^^^^^^^^^^^

warning: enum `MergeResult` is never used --> optd-core/src/optimizer/memo.rs:14:17 | 14 | pub(crate) enum MergeResult { | ^^^^^^^^^^^

warning: trait `Memoize` is never used --> optd-core/src/optimizer/memo.rs:37:18 | 37 | pub(crate) trait Memoize: Send + Sync + 'static { | ^^^^^^^

warning: struct `Representative` is never constructed --> optd-core/src/optimizer/merge_repr.rs:8:12 | 8 | pub struct Representative<T> { | ^^^^^^^^^^^^^^

warning: associated items `new`, `find`, `merge`, and `find_with_compression` are never used --> optd-core/src/optimizer/merge_repr.rs:14:19 | 12 | impl<T: Eq + Hash + Clone> Representative<T> { | -------------------------------------------- associated items in this implementation 13 | /// Creates a new empty Representative 14 | pub(super) fn new() -> Self { | ^^^ ... 24 | pub(super) fn find(&self, x: &T) -> T { | ^^^^ ... 36 | pub(super) fn merge(&mut self, old: &T, new: &T) -> T { | ^^^^^ ... 54 | fn find_with_compression(&mut self, x: &T) -> T { | ^^^^^^^^^^^^^^^^^^^^^

warning: methods `subscribe_to_group`, `subscribe_to_goal`, `explore_group`, and `explore_goal` are never used --> optd-core/src/optimizer/subscriptions.rs:26:25 | 18 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 26 | pub(super) async fn subscribe_to_group( | ^^^^^^^^^^^^^^^^^^ ... 67 | pub(super) async fn subscribe_to_goal( | ^^^^^^^^^^^^^^^^^ ... 106 | async fn explore_group(&mut self, group_id: GroupId) { | ^^^^^^^^^^^^^ ... 156 | async fn explore_goal(&mut self, goal: Goal) { | ^^^^^^^^^^^^

warning: unused import: `self` --> optd-core/src/optimizer/handlers.rs:11:17 | 11 | group::{self, GroupId}, | ^^^^ | = note: `#[warn(unused_imports)]` on by default

warning: unused variable: `plan` --> optd-core/src/optimizer/handlers.rs:130:9 | 130 | plan: PartialPhysicalPlan, | ^^^^ help: if this is intentional, prefix it with an underscore: `_plan` | = note: `#[warn(unused_variables)]` on by default

warning: unused variable: `goal` --> optd-core/src/optimizer/handlers.rs:131:9 | 131 | goal: Goal, | ^^^^ help: if this is intentional, prefix it with an underscore: `_goal`

warning: unused variable: `expr` --> optd-core/src/optimizer/handlers.rs:139:9 | 139 | expr: OptimizedExpression, | ^^^^ help: if this is intentional, prefix it with an underscore: `_expr`

warning: unused variable: `goal` --> optd-core/src/optimizer/handlers.rs:140:9 | 140 | goal: Goal, | ^^^^ help: if this is intentional, prefix it with an underscore: `_goal`

warning: type `engine::error::EngineError` is more private than the item `error::Error::Engine::0` --> optd-core/src/error.rs:7:12 | 7 | Engine(EngineError), | ^^^^^^^^^^^ field `error::Error::Engine::0` is reachable at visibility `pub` | note: but type `engine::error::EngineError` is only usable at visibility `pub(crate)` --> optd-core/src/engine/error.rs:9:1 | 9 | pub(crate) enum EngineError { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ = note: `#[warn(private_interfaces)]` on by default

warning: function `value_to_partial_logical` is never used --> optd-core/src/bridge/into_cir.rs:22:15 | 22 | pub(crate) fn value_to_partial_logical(value: &Value) -> PartialLogicalPlan { | ^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(dead_code)]` on by default

warning: function `value_to_partial_physical` is never used --> optd-core/src/bridge/into_cir.rs:41:15 | 41 | pub(crate) fn value_to_partial_physical(value: &Value) -> PartialPhysicalPlan { | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `value_to_cost` is never used --> optd-core/src/bridge/into_cir.rs:58:15 | 58 | pub(crate) fn value_to_cost(value: &Value) -> Cost { | ^^^^^^^^^^^^^

warning: function `value_to_logical_properties` is never used --> optd-core/src/bridge/into_cir.rs:66:15 | 66 | pub(crate) fn value_to_logical_properties(properties_value: &Value) -> LogicalProperties { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `RuleResult` is never used --> optd-core/src/engine/mod.rs:44:6 | 44 | type RuleResult<T> = Result<T, Error>; | ^^^^^^^^^^

warning: struct `Engine` is never constructed --> optd-core/src/engine/mod.rs:48:19 | 48 | pub(crate) struct Engine<E: Expander> { | ^^^^^^

warning: multiple associated items are never used --> optd-core/src/engine/mod.rs:57:19 | 55 | impl<E: Expander> Engine<E> { | --------------------------- associated items in this implementation 56 | /// Creates a new engine with the given context and expander. 57 | pub(crate) fn new(context: Context, expander: E) -> Self { | ^^^ ... 71 | pub(crate) fn with_context(self, context: Context) -> Self { | ^^^^^^^^^^^^ ... 89 | pub(crate) fn match_and_apply_logical_rule( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 114 | pub(crate) fn match_and_apply_implementation_rule( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 142 | pub(crate) fn cost_plan(self, plan: &PartialPhysicalPlan) -> CostStream { | ^^^^^^^^^ ... 164 | pub(crate) async fn derive_properties( | ^^^^^^^^^^^^^^^^^ ... 190 | fn create_rule_call(&self, rule_name: &str, args: Vec<Value>) -> Arc<Expr> { | ^^^^^^^^^^^^^^^^ ... 205 | fn process_rule_result<T, F>(result: Result<Value, Error>, transform: F) -> RuleResult<T> | ^^^^^^^^^^^^^^^^^^^

warning: variants `Fail` and `NoResult` are never constructed --> optd-core/src/engine/error.rs:11:5 | 9 | pub(crate) enum EngineError { | ----------- variants in this enum 10 | /// A failure triggered by a Fail expression in the HIR. 11 | Fail(String), | ^^^^ 12 | /// A failure triggered by the failure of returning any result. 13 | NoResult, | ^^^^^^^^ | = note: `EngineError` has derived impls for the traits `Debug` and `Clone`, but these are intentionally ignored during dead code analysis

warning: trait `Evaluate` is never used --> optd-core/src/engine/eval/mod.rs:36:18 | 36 | pub(crate) trait Evaluate { | ^^^^^^^^

warning: function `evaluate_core_expr` is never used --> optd-core/src/engine/eval/core.rs:30:15 | 30 | pub(super) fn evaluate_core_expr<E>(data: CoreData<Arc<Expr>>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^

warning: function `evaluate_collection` is never used --> optd-core/src/engine/eval/core.rs:49:4 | 49 | fn evaluate_collection<E>( | ^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_map` is never used --> optd-core/src/engine/eval/core.rs:70:4 | 70 | fn evaluate_map<E>(items: Vec<(Arc<Expr>, Arc<Expr>)>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^

warning: function `evaluate_fail` is never used --> optd-core/src/engine/eval/core.rs:101:4 | 101 | fn evaluate_fail<E>(msg: Arc<Expr>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^

warning: function `evaluate_pattern_match` is never used --> optd-core/src/engine/eval/expr.rs:76:4 | 76 | fn evaluate_pattern_match<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_if_then_else` is never used --> optd-core/src/engine/eval/expr.rs:101:4 | 101 | fn evaluate_if_then_else<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_let_binding` is never used --> optd-core/src/engine/eval/expr.rs:137:4 | 137 | fn evaluate_let_binding<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_binary_expr` is never used --> optd-core/src/engine/eval/expr.rs:165:4 | 165 | fn evaluate_binary_expr<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_unary_expr` is never used --> optd-core/src/engine/eval/expr.rs:189:4 | 189 | fn evaluate_unary_expr<E>(op: UnaryOp, expr: Arc<Expr>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_function_call` is never used --> optd-core/src/engine/eval/expr.rs:202:4 | 202 | fn evaluate_function_call<E>(fun: Arc<Expr>, args: Vec<Arc<Expr>>, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_closure_call` is never used --> optd-core/src/engine/eval/expr.rs:233:4 | 233 | fn evaluate_closure_call<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_rust_udf_call` is never used --> optd-core/src/engine/eval/expr.rs:263:4 | 263 | fn evaluate_rust_udf_call<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_reference` is never used --> optd-core/src/engine/eval/expr.rs:279:4 | 279 | fn evaluate_reference<E>(ident: String, engine: Engine<E>) -> ValueStream | ^^^^^^^^^^^^^^^^^^

warning: type alias `MatchResult` is never used --> optd-core/src/engine/eval/match.rs:26:17 | 26 | pub(crate) type MatchResult = (Value, Option<Context>); | ^^^^^^^^^^^

warning: function `try_match_arms` is never used --> optd-core/src/engine/eval/match.rs:32:15 | 32 | pub(super) fn try_match_arms<E>( | ^^^^^^^^^^^^^^

warning: function `match_pattern` is never used --> optd-core/src/engine/eval/match.rs:79:4 | 79 | fn match_pattern<E>(value: Value, pattern: Pattern, engine: Engine<E>) -> MatchResultStream | ^^^^^^^^^^^^^

warning: function `match_pattern_combinations` is never used --> optd-core/src/engine/eval/match.rs:164:4 | 164 | fn match_pattern_combinations<E, I>(pairs: I, engine: Engine<E>) -> VecMatchResultStream | ^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `match_array_pattern` is never used --> optd-core/src/engine/eval/match.rs:176:4 | 176 | fn match_array_pattern<E>( | ^^^^^^^^^^^^^^^^^^^

warning: function `match_struct_pattern` is never used --> optd-core/src/engine/eval/match.rs:234:4 | 234 | fn match_struct_pattern<E>( | ^^^^^^^^^^^^^^^^^^^^

warning: function `match_operator_pattern` is never used --> optd-core/src/engine/eval/match.rs:284:4 | 284 | fn match_operator_pattern<E>( | ^^^^^^^^^^^^^^^^^^^^^^

warning: function `match_against_expanded_values` is never used --> optd-core/src/engine/eval/match.rs:373:4 | 373 | fn match_against_expanded_values<E, S>( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `OperatorStream` is never used --> optd-core/src/engine/eval/operator.rs:31:6 | 31 | type OperatorStream = Pin<Box<dyn Stream<Item = Result<Operator<Value>, Error>> + Send>>; | ^^^^^^^^^^^^^^

warning: function `evaluate_logical_operator` is never used --> optd-core/src/engine/eval/operator.rs:38:15 | 38 | pub(super) fn evaluate_logical_operator<E>( | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_physical_operator` is never used --> optd-core/src/engine/eval/operator.rs:56:15 | 56 | pub(super) fn evaluate_physical_operator<E>( | ^^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `explore_operator_data` is never used --> optd-core/src/engine/eval/operator.rs:78:4 | 78 | fn explore_operator_data<E>( | ^^^^^^^^^^^^^^^^^^^^^

warning: function `explore_children` is never used --> optd-core/src/engine/eval/operator.rs:100:4 | 100 | fn explore_children<E>( | ^^^^^^^^^^^^^^^^

warning: methods `expand_all_exprs`, `expand_optimized_expr`, and `retrieve_properties` are never used --> optd-core/src/engine/expander.rs:13:8 | 9 | pub trait Expander: Clone + Send + Sync + 'static { | -------- methods in this trait ... 13 | fn expand_all_exprs(&self, group_id: GroupId) -> ValueStream; | ^^^^^^^^^^^^^^^^ ... 19 | fn expand_optimized_expr(&self, physical_goal: &Goal) -> ValueStream; | ^^^^^^^^^^^^^^^^^^^^^ ... 24 | async fn retrieve_properties(&self, group_id: GroupId) -> Value; | ^^^^^^^^^^^^^^^^^^^

warning: type alias `VecValueStream` is never used --> optd-core/src/engine/utils/streams.rs:29:17 | 29 | pub(crate) type VecValueStream = Pin<Box<dyn Stream<Item = Result<Vec<Value>, Error>> + Send>>; | ^^^^^^^^^^^^^^

warning: type alias `PartialLogicalPlanStream` is never used --> optd-core/src/engine/utils/streams.rs:35:17 | 35 | pub(crate) type PartialLogicalPlanStream = | ^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `PartialPhysicalPlanStream` is never used --> optd-core/src/engine/utils/streams.rs:42:17 | 42 | pub(crate) type PartialPhysicalPlanStream = | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `MatchResultStream` is never used --> optd-core/src/engine/utils/streams.rs:46:17 | 46 | pub(crate) type MatchResultStream = Pin<Box<dyn Stream<Item = Result<MatchResult, Error>> + Send>>; | ^^^^^^^^^^^^^^^^^

warning: type alias `VecMatchResultStream` is never used --> optd-core/src/engine/utils/streams.rs:49:17 | 49 | pub(crate) type VecMatchResultStream = | ^^^^^^^^^^^^^^^^^^^^

warning: type alias `CostStream` is never used --> optd-core/src/engine/utils/streams.rs:53:17 | 53 | pub(crate) type CostStream = Pin<Box<dyn Stream<Item = Result<Cost, Error>> + Send>>; | ^^^^^^^^^^

warning: function `process_items_in_sequence` is never used --> optd-core/src/engine/utils/streams.rs:74:15 | 74 | pub(crate) fn process_items_in_sequence<E, I, T, F>( | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `evaluate_all_combinations` is never used --> optd-core/src/engine/utils/streams.rs:147:15 | 147 | pub(crate) fn evaluate_all_combinations<E, I>(items: I, engine: Engine<E>) -> VecValueStream | ^^^^^^^^^^^^^^^^^^^^^^^^^

warning: function `propagate_error` is never used --> optd-core/src/engine/utils/streams.rs:166:15 | 166 | pub(crate) fn propagate_error<T>(e: Error) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> | ^^^^^^^^^^^^^^^

warning: function `propagate_success` is never used --> optd-core/src/engine/utils/streams.rs:183:15 | 183 | pub(crate) fn propagate_success<T>(value: T) -> Pin<Box<dyn Stream<Item = Result<T, Error>> + Send>> | ^^^^^^^^^^^^^^^^^

warning: function `stream_from_result` is never used --> optd-core/src/engine/utils/streams.rs:208:15 | 208 | pub(crate) fn stream_from_result<'a, T, U, F, Fut>( | ^^^^^^^^^^^^^^^^^^

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:91:20 | 91 | SubscribeGroup(GroupId, Sender<LogicalExpression>), | -------------- ^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 91 - SubscribeGroup(GroupId, Sender<LogicalExpression>), 91 + SubscribeGroup((), ()), |

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:97:19 | 97 | SubscribeGoal(Goal, Sender<OptimizedExpression>), | ------------- ^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 97 - SubscribeGoal(Goal, Sender<OptimizedExpression>), 97 + SubscribeGoal((), ()), |

warning: fields `0` and `1` are never read --> optd-core/src/optimizer/mod.rs:102:24 | 102 | RetrieveProperties(GroupId, oneshot::Sender<LogicalProperties>), | ------------------ ^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | | | fields in this variant | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis help: consider changing the fields to be of unit type to suppress this warning while preserving the field numbering, or remove the fields | 102 - RetrieveProperties(GroupId, oneshot::Sender<LogicalProperties>), 102 + RetrieveProperties((), ()), |

warning: variants `OptimizeRequest`, `EgestOptimized`, `NewLogicalPartial`, `NewPhysicalPartial`, `NewOptimizedExpression`, and `CreateGroup` are never constructed --> optd-core/src/optimizer/mod.rs:60:5 | 55 | enum OptimizerMessage { | ---------------- variants in this enum ... 60 | OptimizeRequest(OptimizeRequest), | ^^^^^^^^^^^^^^^ ... 67 | EgestOptimized(OptimizedExpression, Sender<PhysicalPlan>), | ^^^^^^^^^^^^^^ ... 70 | NewLogicalPartial(PartialLogicalPlan, GroupId), | ^^^^^^^^^^^^^^^^^ ... 75 | NewPhysicalPartial(PartialPhysicalPlan, Goal), | ^^^^^^^^^^^^^^^^^^ ... 80 | NewOptimizedExpression(OptimizedExpression, Goal), | ^^^^^^^^^^^^^^^^^^^^^^ ... 86 | CreateGroup(LogicalProperties, LogicalExpression, i64), | ^^^^^^^^^^^ | = note: `OptimizerMessage` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis

warning: struct `PendingMessage` is never constructed --> optd-core/src/optimizer/mod.rs:110:8 | 110 | struct PendingMessage { | ^^^^^^^^^^^^^^

warning: struct `Optimizer` is never constructed --> optd-core/src/optimizer/mod.rs:127:8 | 127 | struct Optimizer<M: Memoize> { | ^^^^^^^^^

warning: associated items `launch` and `run` are never used --> optd-core/src/optimizer/mod.rs:199:12 | 194 | impl<M: Memoize> Optimizer<M> { | ----------------------------- associated items in this implementation ... 199 | pub fn launch(memo: M, hir: HIR) -> Sender<OptimizeRequest> { | ^^^^^^ ... 254 | async fn run(mut self) { | ^^^

warning: methods `egest_best_plan` and `egest_child_plan` are never used --> optd-core/src/optimizer/egest.rs:30:25 | 16 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 30 | pub(super) async fn egest_best_plan( | ^^^^^^^^^^^^^^^ ... 69 | async fn egest_child_plan( | ^^^^^^^^^^^^^^^^

warning: multiple methods are never used --> optd-core/src/optimizer/handlers.rs:28:25 | 25 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 28 | pub(super) async fn process_optimize_request( | ^^^^^^^^^^^^^^^^^^^^^^^^ ... 72 | pub(super) async fn process_egest_optimized( | ^^^^^^^^^^^^^^^^^^^^^^^ ... 93 | pub(super) async fn process_new_logical_partial( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 128 | pub(super) async fn process_new_physical_partial( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 137 | pub(super) async fn process_new_optimized_expression( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 147 | pub(super) async fn process_create_group( | ^^^^^^^^^^^^^^^^^^^^ ... 163 | pub(super) async fn process_group_subscription( | ^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 174 | pub(super) async fn process_goal_subscription( | ^^^^^^^^^^^^^^^^^^^^^^^^^ ... 185 | pub(super) async fn process_retrieve_properties( | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ... 208 | async fn handle_merge_result(&mut self, result: MergeResult) { | ^^^^^^^^^^^^^^^^^^^ ... 289 | async fn resolve_dependencies(&mut self, completed_job_id: i64) { | ^^^^^^^^^^^^^^^^^^^^

warning: enum `LogicalIngest` is never used --> optd-core/src/optimizer/ingest.rs:19:17 | 19 | pub(super) enum LogicalIngest { | ^^^^^^^^^^^^^

warning: enum `InternalLogicalIngest` is never used --> optd-core/src/optimizer/ingest.rs:30:6 | 30 | enum InternalLogicalIngest { | ^^^^^^^^^^^^^^^^^^^^^

warning: multiple methods are never used --> optd-core/src/optimizer/ingest.rs:45:25 | 35 | impl<M: Memoize> Optimizer<M> { | ----------------------------- methods in this implementation ... 45 | pub(super) async fn try_ingest_logical( | ^^^^^^^^^^^^^^^^^^ ... 99 | async fn ingest_logical_plan( | ^^^^^^^^^^^^^^^^^^^ ... 125 | async fn ingest_physical_plan( | ^^^^^^^^^^^^^^^^^^^^ ... 153 | async fn ingest_logical_operator( | ^^^^^^^^^^^^^^^^^^^^^^^ ... 231 | async fn ingest_physical_operator( | ^^^^^^^^^^^^^^^^^^^^^^^^ ... 266 | async fn process_logical_child( | ^^^^^^^^^^^^^^^^^^^^^ ... 293 | async fn process_physical_child( | ^^^^^^^^^^^^^^^^^^^^^^

warning: type alias `MemoizeResult` is never used --> optd-core/src/optimizer/memo.rs:11:17 | 11 | pub(crate) type MemoizeResult<T> = Result<T, Error>; | ^^^^^^^^^^^^^

warning: enum `MergeResult` is never used --> optd-core/src/optimizer/memo.rs:14:17 | 14 | pub(crate) enum MergeResult { | ^^^^^^^^^^^

warning: trait `Memoize` is never used --> optd-core/src/optimizer/memo.rs:37:18 | 37 | pub(crate) trait Memoize: Send + Sync + 'static { | ^^^^^^^

warning: struct `Representative` is never constructed --> optd-core/src/optimizer/merge_repr.rs:8:12 | 8 | pub struct Representative<T> { | ^^^^^^^^^^^^^^

warning: associated items `new`, `find`, `merge`, and `find_with_compression` are never used --> optd-core/src/optimizer/merge_repr.rs:14:19 | 12 | impl<T: Eq + Hash + Clone> Representative<T> { | -------------------------------------------- associated items in this implementation 13 | /// Creates a new empty Representative 14 | pub(super) fn new() -> Self { | ^^^ ... 24 | pub(super) fn find(&self, x: &T) -> T { | ^^^^ ... 36 | pub(super) fn merge(&mut self, old: &T, new: &T) -> T { | ^^^^^ ... 54 | fn find_with_compression(&mut self, x: &T) -> T { | ^^^^^^^^^^^^^^^^^^^^^