Merge pull request #22 from isankadn/dev

na

README.MD

@@ -2,4 +2,4 @@
 
 Inside "mongo-to-clickhouse" container run this.
 
-./historical_data saikyo 2020-01-01 2021-12-31
+RUST_LOG=info ./historical_data saikyo 2020-01-01 2021-12-31

historical_data/src/main.rs

@@ -529,7 +529,13 @@ async fn main() -> Result<(), Box<dyn Error>> {
             .unwrap();
     });
 
-    tokio::spawn(retry_failed_batches(app_state));
+    let handle = tokio::spawn(retry_failed_batches(app_state));
+
+    if let Err(e) = handle.await {
+        error!("retry_failed_batches task failed: {}", e);
+    } else {
+        info!("Processing finished, exiting...");
+    }
 
     signal::ctrl_c().await?;
     info!("Received shutdown signal, shutting down gracefully...");