diff --git a/crates/bin/pd/src/migrate/testnet72.rs b/crates/bin/pd/src/migrate/testnet72.rs index aa8ea49d62..09f4401ed0 100644 --- a/crates/bin/pd/src/migrate/testnet72.rs +++ b/crates/bin/pd/src/migrate/testnet72.rs @@ -1,7 +1,7 @@ //! Contains functions related to the migration script of Testnet72 use anyhow; -use cnidarium::{Snapshot, StateDelta, StateRead, Storage}; +use cnidarium::{Snapshot, StateDelta, StateRead, StateWrite, Storage}; use futures::StreamExt as _; use jmt::RootHash; use penumbra_app::app::StateReadExt as _; @@ -114,12 +114,12 @@ async fn translate_compact_block_storage( ctx: Context, delta: &mut StateDelta, ) -> anyhow::Result<()> { - let mut stream = delta.prefix_raw("compactblock/"); + let mut stream = delta.nonverifiable_prefix_raw("compactblock/".as_bytes()); while let Some(r) = stream.next().await { - let (key, compactblack_bytes): (String, Vec) = r?; + let (key, compactblack_bytes) = r?; let block = pb::compact_block::v1::CompactBlock::decode(compactblack_bytes.as_slice())?; let block = ctx.translate_compact_block(block).await?; - delta.put_proto(key, block); + delta.nonverifiable_put_raw(key, block.encode_to_vec()); } Ok(()) }