Move core kmerge_batch into backend

nautechsystems · Oct 21, 2023 · dde15bb · dde15bb
1 parent 05a1cc9
commit dde15bb
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/...ilus_core/persistence/src/kmerge_batch.rs → ...e/persistence/src/backend/kmerge_batch.rs b/...ilus_core/persistence/src/kmerge_batch.rs → ...e/persistence/src/backend/kmerge_batch.rs
diff --git a/nautilus_core/persistence/src/backend/mod.rs b/nautilus_core/persistence/src/backend/mod.rs
@@ -13,4 +13,5 @@
 //  limitations under the License.
 // -------------------------------------------------------------------------------------------------
 
+pub mod kmerge_batch;
 pub mod session;
diff --git a/nautilus_core/persistence/src/backend/session.rs b/nautilus_core/persistence/src/backend/session.rs
@@ -27,9 +27,9 @@ use nautilus_core::ffi::cvec::CVec;
 use nautilus_model::data::{Data, HasTsInit};
 use pyo3::prelude::*;
 
-use crate::{
-    arrow::{DataStreamingError, DecodeDataFromRecordBatch, EncodeToRecordBatch, WriteStream},
-    kmerge_batch::{EagerStream, ElementBatchIter, KMerge},
+use super::kmerge_batch::{EagerStream, ElementBatchIter, KMerge};
+use crate::arrow::{
+    DataStreamingError, DecodeDataFromRecordBatch, EncodeToRecordBatch, WriteStream,
 };
 
 #[derive(Debug, Default)]

diff --git a/nautilus_core/persistence/src/lib.rs b/nautilus_core/persistence/src/lib.rs
@@ -15,7 +15,6 @@
 
 pub mod arrow;
 pub mod backend;
-mod kmerge_batch;
 
 #[cfg(feature = "python")]
 pub mod python;