Add more debug messages to alpenrose

src/alpenrose/main.rs

@@ -73,6 +73,8 @@ pub struct RealtimeFeedFetch {
 async fn main() -> Result<(), Box<dyn Error + Sync + Send>> {
     let this_worker_id = Arc::new(Uuid::new_v4().to_string());
 
+    println!("Worker id {}", this_worker_id);
+
     // if a node drops out, ingestion will be automatically reassigned to the other nodes
 
     //hands off data to aspen to do additional cleanup and processing, Aspen will perform association with the GTFS schedule data + update dynamic graphs for routing and map representation,
@@ -95,6 +97,8 @@ async fn main() -> Result<(), Box<dyn Error + Sync + Send>> {
         .await
         .unwrap();
 
+    println!("Connected to zookeeper!");
+
     let conn_pool = arc_conn_pool.as_ref();
     let conn_pre = conn_pool.get().await;
     let conn = &mut conn_pre?;