ref: fix circular dependencies (#844)

Moves the sparrow-plan-execution test into sparrow-session to avoid circular dependencies.
kaskada-ai · Nov 1, 2023 · 0ad4680 · 0ad4680
1 parent 7508a6d
commit 0ad4680
Show file tree

Hide file tree

Showing 9 changed files with 12 additions and 12 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/sparrow-batch/Cargo.toml b/crates/sparrow-batch/Cargo.toml
@@ -25,7 +25,6 @@ proptest = { workspace = true, optional = true }
 
 [dev-dependencies]
 sparrow-testing = { path = "../sparrow-testing" }
-sparrow-merge = { path = "../sparrow-merge" }
 proptest.workspace = true
 
 [lib]

diff --git a/crates/sparrow-plan-execution/Cargo.toml b/crates/sparrow-plan-execution/Cargo.toml
@@ -36,7 +36,6 @@ index_vec.workspace = true
 sparrow-backend = { path = "../sparrow-backend" }
 sparrow-expressions = { path = "../sparrow-expressions" }
 sparrow-logical = { path = "../sparrow-logical" }
-sparrow-session = { path = "../sparrow-session" }
 sparrow-testing = { path = "../sparrow-testing" }
 
 [lib]

diff --git a/crates/sparrow-plan-execution/src/lib.rs b/crates/sparrow-plan-execution/src/lib.rs
@@ -31,9 +31,6 @@ mod error;
 mod source_tasks;
 mod write_pipeline;
 
-#[cfg(test)]
-mod tests;
-
 pub use error::*;
 
 use crate::source_tasks::SourceTasks;

diff --git a/crates/sparrow-session/Cargo.toml b/crates/sparrow-session/Cargo.toml
@@ -35,6 +35,8 @@ tokio-stream.workspace = true
 uuid.workspace = true
 
 [dev-dependencies]
+sparrow-expressions = { path = "../sparrow-expressions" }
+sparrow-testing = { path = "../sparrow-testing" }
 
 [lib]
 bench = false

diff --git a/crates/sparrow-session/src/partitioned.rs b/crates/sparrow-session/src/partitioned.rs
@@ -1,2 +1,5 @@
 mod session;
 pub use session::*;
+
+#[cfg(tests)]
+mod tests;
diff --git a/crates/sparrow-session/src/partitioned/partitioned.rs b/crates/sparrow-session/src/partitioned/partitioned.rs
@@ -0,0 +1 @@
+mod basic_tests;
diff --git a/crates/sparrow-plan-execution/src/tests.rs → ...sion/src/partitioned/tests/basic_tests.rs b/crates/sparrow-plan-execution/src/tests.rs → ...sion/src/partitioned/tests/basic_tests.rs
@@ -1,17 +1,14 @@
+use crate::partitioned::Session;
 use arrow_array::cast::AsArray;
 use arrow_array::{Int64Array, RecordBatch, TimestampNanosecondArray, UInt64Array};
 use sparrow_interfaces::source::{Source, SourceExt};
 use sparrow_io::in_memory::InMemorySource;
 use sparrow_logical::ExprRef;
-use sparrow_session::partitioned::Session;
 use std::sync::Arc;
 
 use arrow_schema::{DataType, Field, Schema};
 
-fn query(
-    session: &Session,
-    source: ExprRef,
-) -> error_stack::Result<ExprRef, sparrow_session::Error> {
+fn query(session: &Session, source: ExprRef) -> error_stack::Result<ExprRef, crate::Error> {
     let a_str = session.add_literal(sparrow_logical::Literal::new_str("a"))?;
     let a = session.add_expr("fieldref", vec![source.clone(), a_str])?;
 

diff --git a/crates/sparrow-session/src/tests.rs b/crates/sparrow-session/src/tests.rs
@@ -0,0 +1,2 @@
+//! Partitioned execution tests
+mod partitioned;