crate core-history #2, add recording service

Author: rampage644

crates/core-executor/src/dedicated_executor.rs

@@ -14,7 +14,6 @@ use datafusion::physical_plan::stream::RecordBatchStreamAdapter;
 use datafusion_common::DataFusionError;
 use datafusion_common::error::GenericError;
 use datafusion_physical_plan::SendableRecordBatchStream;
-use futures::executor;
 use futures::stream::BoxStream;
 use futures::{
     Future, FutureExt, Stream, StreamExt, TryFutureExt,

crates/core-executor/src/utils.rs

@@ -21,7 +21,7 @@ use std::sync::Arc;
 use strum::{Display, EnumString};
 
 // This isn't the best way to do this, but it'll do for now
-// TODO: Revisit
+// TODO: Should be moved to api-snowflake-rest
 pub struct Config {
     pub dbt_serialization_format: DataSerializationFormat,
 }

crates/core-history/Cargo.toml

@@ -6,8 +6,13 @@ license-file.workspace = true
 
 [dependencies]
 core-utils = { path = "../core-utils" }
+core-executor = { path = "../core-executor" }
+core-metastore = { path = "../core-metastore" }
+
 bytes = { workspace = true }
+datafusion = { workspace = true }
 chrono = { workspace = true, features = ["serde"] }
+indexmap = { version = "2.7.1" }
 serde = { workspace = true }
 serde_json = { workspace = true }
 utoipa = { workspace = true }

crates/core-history/src/lib.rs

@@ -1,7 +1,9 @@
 pub mod entities;
 pub mod history_store;
+pub mod recording_service;
 pub mod store;
 
 pub use entities::*;
 pub use history_store::*;
+pub use recording_service::RecordingExecutionService;
 pub use store::*;