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();