cleanup

synth/src/cli/mongo.rs

@@ -159,7 +159,6 @@ impl ExportStrategy for MongoExportStrategy {
         info!("Connecting to database at {} ...", &self.uri_string);
 
         let mut client = Client::with_options(client_options)?;
-        // let mut client = Client::with_uri_str(&self.uri_string)?;
 
         match sample {
             SamplerOutput::Collection(name, value) => {

synth/src/datasource/mysql_datasource.rs

@@ -10,7 +10,6 @@ use rust_decimal::Decimal;
 use sqlx::mysql::{MySqlColumn, MySqlPoolOptions, MySqlRow};
 use sqlx::{Column, MySql, Pool, Row, TypeInfo};
 use std::collections::BTreeMap;
-use std::time::Duration;
 use synth_core::schema::number_content::{F64, I16, I32, I64, I8, U64};
 use synth_core::schema::{
     ChronoValueType, DateTimeContent, NumberContent, RangeStep, RegexContent, StringContent,
@@ -28,7 +27,6 @@ pub struct MySqlConnectParams {
     pub(crate) concurrency: usize,
 }
 
-#[derive(Clone)]
 pub struct MySqlDataSource {
     pool: Pool<MySql>,
     concurrency: usize,
@@ -42,7 +40,6 @@ impl DataSource for MySqlDataSource {
         task::block_on(async {
             let pool = MySqlPoolOptions::new()
                 .max_connections(connect_params.concurrency.try_into().unwrap())
-                .acquire_timeout(Duration::from_secs(600))
                 .connect(connect_params.uri.as_str())
                 .await?;
 

synth/src/datasource/relational_datasource.rs

@@ -226,8 +226,6 @@ where
         collection_name
     );
 
-    let mut num_jobs = 0;
-
     let semaphore = Arc::new(Semaphore::new(max_concurrency));
     for rows in collection_chunks {
         let permit = semaphore.clone().acquire_arc().await;
@@ -260,15 +258,10 @@ where
             drop(permit);
             result
         });
-        num_jobs += 1;
 
         futures.push(future);
     }
 
-    info!(
-        "Waiting for {} jobs for collection {}...",
-        num_jobs, collection_name
-    );
     let results = join_all(futures).await;
 
     if let Err(e) = results.into_iter().bcollect::<Vec<_>>() {