Merge pull request #172 from influxdata/crepererum/df-exec-dep

refactor: reduce dependencies of `query` crate

Author: crepererum

Cargo.lock

@@ -21,6 +21,7 @@ arrow = { version = "56.2.0", default-features = false, features = ["ipc"] }
 chrono = { version = "0.4.42", default-features = false }
 datafusion = { version = "50.3.0", default-features = false }
 datafusion-common = { version = "50.3.0", default-features = false }
+datafusion-execution = { version = "50.3.0", default-features = false }
 datafusion-expr = { version = "50.3.0", default-features = false }
 datafusion-sql = { version = "50.3.0", default-features = false }
 datafusion-udf-wasm-arrow2bytes = { path = "arrow2bytes", version = "0.1.0" }

Cargo.toml

@@ -5,15 +5,16 @@ edition.workspace = true
 license.workspace = true
 
 [dependencies]
-datafusion.workspace = true
 datafusion-common.workspace = true
+datafusion-execution.workspace = true
 datafusion-expr.workspace = true
 datafusion-sql.workspace = true
 datafusion-udf-wasm-host.workspace = true
 sqlparser.workspace = true
 tokio.workspace = true
 
 [dev-dependencies]
+datafusion.workspace = true
 datafusion-udf-wasm-bundle = { workspace = true, features = ["python"] }
 datafusion-udf-wasm-host = { workspace = true }
 insta.workspace = true

query/Cargo.toml

@@ -4,8 +4,8 @@
 use std::collections::HashMap;
 use std::pin::Pin;
 
-use datafusion::execution::TaskContext;
 use datafusion_common::{DataFusionError, Result as DataFusionResult};
+use datafusion_execution::TaskContext;
 use datafusion_sql::parser::{DFParserBuilder, Statement};
 use sqlparser::ast::{CreateFunctionBody, Expr, Statement as SqlStatement, Value};
 use sqlparser::dialect::dialect_from_str;

query/src/lib.rs

@@ -7,11 +7,10 @@
 
 use std::collections::HashMap;
 
-use datafusion::{
-    assert_batches_eq,
-    prelude::{DataFrame, SessionContext},
+use datafusion::prelude::{DataFrame, SessionContext};
+use datafusion_common::{
+    Result as DataFusionResult, assert_batches_eq, test_util::batches_to_string,
 };
-use datafusion_common::{Result as DataFusionResult, test_util::batches_to_string};
 use datafusion_udf_wasm_host::WasmPermissions;
 use datafusion_udf_wasm_query::{
     ComponentFn, Lang, ParsedQuery, UdfQueryParser,