From 20e02483dcd73ea39b1507ca2e1c61c3c1fe8997 Mon Sep 17 00:00:00 2001 From: Kyler Chin <7539174+kylerchin@users.noreply.github.com> Date: Tue, 23 Apr 2024 20:52:20 -0700 Subject: [PATCH] Leader assignment debug messages --- src/aspen/leader_thread.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/aspen/leader_thread.rs b/src/aspen/leader_thread.rs index 607d4e9f..dd335c6b 100644 --- a/src/aspen/leader_thread.rs +++ b/src/aspen/leader_thread.rs @@ -183,6 +183,7 @@ pub async fn aspen_leader_thread( } if chateau_data_changed || aspen_workers_list_changed { + println!("Assigning tasks to workers...."); // divide it into chunks if let Some(chateau_list_lock) = chateau_list_lock.as_ref() { for (index, (chateau_id, chateau)) in @@ -239,6 +240,7 @@ pub async fn aspen_leader_thread( .unwrap(); } } + println!("Assigned {} chateaus across {} workers", chateau_list_lock.chateaus.len(), workers_nodes_lock.len()); } }