From 4212ea0d777d43265b02802111c0009d985796c0 Mon Sep 17 00:00:00 2001 From: Kyler Chin <7539174+kylerchin@users.noreply.github.com> Date: Wed, 24 Apr 2024 13:33:03 -0700 Subject: [PATCH] Add more debug messages to alpenrose --- src/alpenrose/main.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/alpenrose/main.rs b/src/alpenrose/main.rs index ab1b5c3c..2257df47 100644 --- a/src/alpenrose/main.rs +++ b/src/alpenrose/main.rs @@ -73,6 +73,8 @@ pub struct RealtimeFeedFetch { async fn main() -> Result<(), Box> { 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> { .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?;