diff --git a/migrate_csplus/src/data_fetch.rs b/migrate_csplus/src/data_fetch.rs index 2991fbc8bb099dbe759d800275b9883307c886fe..c839abf4630be053c7569133145938e88714ff74 100644 --- a/migrate_csplus/src/data_fetch.rs +++ b/migrate_csplus/src/data_fetch.rs @@ -53,7 +53,7 @@ pub async fn fetch_profiles( } /// Fetches a batch of data based on the scroll ID and time. -pub async fn fetch_scroll_batch( +async fn fetch_scroll_batch( scroll_id: &str, scroll_time: &str, ) -> Result<ScrollResponse, Box<dyn Error>> { @@ -69,7 +69,7 @@ pub async fn fetch_scroll_batch( } /// Processes the hits from the fetched data. -pub async fn process_hits( +async fn process_hits( pool: Arc<Mutex<Pool<PostgresConnectionManager<NoTls>>>>, hits: &[Hit], ) -> Result<(), Box<dyn Error>> { diff --git a/migrate_csplus/src/import_only.rs b/migrate_csplus/src/only_fetch_to_json.rs similarity index 100% rename from migrate_csplus/src/import_only.rs rename to migrate_csplus/src/only_fetch_to_json.rs