From fc5b2decd7c8fdc4788927660d3e438ae74367e7 Mon Sep 17 00:00:00 2001 From: Alexander Tesfamichael Date: Mon, 16 Oct 2023 14:36:00 +0200 Subject: [PATCH] feat(migrate-from-gcs): debug log bundle push --- src/bin/migrate-from-gcs.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/bin/migrate-from-gcs.rs b/src/bin/migrate-from-gcs.rs index cb04657..1090678 100644 --- 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();