Skip to content

Commit

Permalink
fix(migrate-from-gcs): remove double ref
Browse files Browse the repository at this point in the history
  • Loading branch information
alextes committed Oct 17, 2023
1 parent 5a50c86 commit 889eb98
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/bin/migrate-from-gcs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -248,7 +248,7 @@ async fn main() -> anyhow::Result<()> {
let keys = slot_bundles.keys().cloned().collect::<Vec<_>>();
trace!("incomplete slot bundles hit limit: {:?}", keys);
let oldest_slot = keys.iter().min().unwrap();
let oldest_slot_payloads = slot_bundles.remove(&oldest_slot).unwrap();
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();
}
Expand Down

0 comments on commit 889eb98

Please sign in to comment.