format

Author: connortsui20

optd/src/core/optimizer/tasks/continue_with_costed.rs

@@ -2,8 +2,8 @@ use crate::{
     core::bridge::from_cir::costed_physical_to_value,
     core::cir::{Cost, PhysicalExpressionId},
     core::error::Error,
-    memo::Memoize,
     core::optimizer::{JobId, Optimizer},
+    memo::Memoize,
 };
 
 use super::{Task, TaskId};

optd/src/core/optimizer/tasks/continue_with_logical.rs

@@ -2,8 +2,8 @@ use crate::{
     core::bridge::from_cir::partial_logical_to_value,
     core::cir::LogicalExpressionId,
     core::error::Error,
-    memo::Memoize,
     core::optimizer::{JobId, Optimizer},
+    memo::Memoize,
 };
 
 use super::{Task, TaskId};

optd/src/core/optimizer/tasks/cost_expr.rs

@@ -6,8 +6,8 @@ use crate::{
     core::bridge::{from_cir::partial_physical_to_value, into_cir::value_to_cost},
     core::cir::{Cost, PhysicalExpressionId},
     core::error::Error,
-    memo::{Memoize, Status},
     core::optimizer::{EngineMessageKind, JobId, Optimizer, Task},
+    memo::{Memoize, Status},
 };
 
 use super::TaskId;

optd/src/core/optimizer/tasks/explore_group.rs

@@ -1,8 +1,8 @@
 use crate::{
     core::cir::{GroupId, LogicalExpressionId},
     core::error::Error,
-    memo::Memoize,
     core::optimizer::Optimizer,
+    memo::Memoize,
 };
 
 use super::{SourceTaskId, Task, TaskId};

optd/src/core/optimizer/tasks/fork_costed.rs

@@ -6,8 +6,8 @@ use crate::dsl::{
 use crate::{
     core::cir::{Cost, GoalId},
     core::error::Error,
-    memo::Memoize,
     core::optimizer::{EngineMessageKind, Optimizer},
+    memo::Memoize,
 };
 
 use super::{SourceTaskId, Task, TaskId};

optd/src/core/optimizer/tasks/fork_logical.rs

@@ -5,8 +5,8 @@ use crate::dsl::{
 
 use crate::{
     core::cir::GroupId,
-    memo::Memoize,
     core::optimizer::{EngineMessageKind, Optimizer},
+    memo::Memoize,
 };
 
 use super::{SourceTaskId, Task, TaskId};

optd/src/core/optimizer/tasks/implement_expr.rs

@@ -9,8 +9,8 @@ use crate::{
     },
     core::cir::{Goal, GoalId, ImplementationRule, LogicalExpressionId},
     core::error::Error,
-    memo::{Memoize, Status},
     core::optimizer::{EngineMessageKind, JobId, Optimizer, Task},
+    memo::{Memoize, Status},
 };
 
 use super::TaskId;

optd/src/core/optimizer/tasks/optimize_goal.rs

@@ -3,8 +3,8 @@ use std::collections::HashSet;
 use crate::{
     core::cir::{Cost, Goal, GoalId, GoalMemberId, PhysicalExpressionId},
     core::error::Error,
-    memo::Memoize,
     core::optimizer::{Optimizer, Task},
+    memo::Memoize,
 };
 
 use super::{SourceTaskId, TaskId};

optd/src/core/optimizer/tasks/optimize_plan.rs

@@ -3,8 +3,8 @@ use futures::{SinkExt, channel::mpsc};
 use crate::{
     core::cir::{Goal, LogicalPlan, PhysicalExpressionId, PhysicalPlan, PhysicalProperties},
     core::error::Error,
-    memo::Memoize,
     core::optimizer::{Optimizer, tasks::SourceTaskId},
+    memo::Memoize,
 };
 
 use super::{Task, TaskId};

optd/src/core/optimizer/tasks/transform_expr.rs

@@ -6,8 +6,8 @@ use crate::{
     core::bridge::{from_cir::partial_logical_to_value, into_cir::value_to_partial_logical},
     core::cir::{LogicalExpressionId, PartialLogicalPlan, TransformationRule},
     core::error::Error,
-    memo::{Memoize, Status},
     core::optimizer::{EngineMessageKind, JobId, Optimizer, Task},
+    memo::{Memoize, Status},
 };
 
 use super::TaskId;

optd/src/memo/memory.rs

@@ -914,8 +914,10 @@ impl MemoryMemo {
                     .entry(GoalMemberId::GoalId(goal_id1))
                     .or_default()
                     .extend(&subscribers);
-                let mut temp_forward_result =
-                    PropagateBestExpression::new(forward_result.physical_expr_id, forward_result.best_cost);
+                let mut temp_forward_result = PropagateBestExpression::new(
+                    forward_result.physical_expr_id,
+                    forward_result.best_cost,
+                );
                 let vec_deque_subscribers =
                     VecDeque::from(subscribers.into_iter().collect::<Vec<_>>());
                 self.propagate_new_member_cost(vec_deque_subscribers, &mut temp_forward_result)