updated batch_process_participant_shares logging

worldcoin · Feb 7, 2024 · d018ef9 · d018ef9
1 parent d100986
commit d018ef9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/coordinator.rs b/src/coordinator.rs
@@ -86,7 +86,8 @@ impl Coordinator {
                 &self.config.queues.shares_queue_url,
             )
             .await?;
-            //TODO: Add metric for number of messages in queue
+
+            metrics::gauge!("uniqueness_check_queue", messages.len() as f64);
 
             for message in messages {
                 let receipt_handle = message
@@ -244,6 +245,7 @@ impl Coordinator {
         // Collect batches of shares
         let (processed_shares_tx, processed_shares_rx) = mpsc::channel(4);
 
+        tracing::info!("Spawning batch worker");
         let batch_worker = tokio::task::spawn(async move {
             loop {
                 // Collect futures of denominator and share batches