clean up and refactor

cmu-db · Feb 12, 2024 · e9befe3 · e9befe3
1 parent 2c52021
commit e9befe3
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/eggstrain/src/execution/operators/mod.rs b/eggstrain/src/execution/operators/mod.rs
@@ -1,7 +1,6 @@
 use async_trait::async_trait;
 use tokio::sync::broadcast::{Receiver, Sender};
 
-pub mod forward_toy;
 pub mod order_by;
 pub mod project;
 

diff --git a/...in/src/execution/operators/forward_toy.rs → .../tests/toy_forward_example/forward_toy.rs b/...in/src/execution/operators/forward_toy.rs → .../tests/toy_forward_example/forward_toy.rs
@@ -1,5 +1,7 @@
-use super::*;
+// use super::*;
 use async_trait::async_trait;
+use crate::execution::operators::*;
+use tokio::sync::broadcast::{Receiver, Sender};
 
 pub struct Forward {
     pub prime: usize,

diff --git a/eggstrain/src/execution/tests/toy_forward_example/mod.rs b/eggstrain/src/execution/tests/toy_forward_example/mod.rs
@@ -1,8 +1,9 @@
 pub mod bad_dag;
+pub mod forward_toy;
 
-use crate::execution::operators::forward_toy::Forward;
-use crate::execution::operators::*;
 use bad_dag::*;
+use crate::execution::operators::*;
+use forward_toy::Forward;
 use std::{collections::VecDeque, sync::Arc};
 use tokio::sync::broadcast::{channel, Receiver, Sender};