feat(migrate-from-gcs): debug log bundle push

ultrasoundmoney · Oct 16, 2023 · fc5b2de · fc5b2de
1 parent 19b4aae
commit fc5b2de
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/bin/migrate-from-gcs.rs b/src/bin/migrate-from-gcs.rs
@@ -245,6 +245,7 @@ async fn main() -> anyhow::Result<()> {
                 if slot_bundles.len() > 4 {
                     let oldest_slot = slot_bundles.keys().min().unwrap().clone();
                     let oldest_slot_payloads = slot_bundles.remove(&oldest_slot).unwrap();
+                    debug!(slot = %oldest_slot, payloads_count = oldest_slot_payloads.len(), "flushing slot bundle");
                     slot_bundle_tx.send(oldest_slot_payloads).await.unwrap();
                 }
             }
@@ -258,6 +259,8 @@ async fn main() -> anyhow::Result<()> {
                 let payloads_count = payloads.len();
                 let slot = &payloads.first().unwrap().slot;
 
+                debug!(slot = %slot, payloads_count, "processing slot bundle");
+
                 let slot_date_time = slot.date_time();
                 let year = slot_date_time.year();
                 let month = slot_date_time.month();