fix: small fixes

metaplex-foundation · Sep 16, 2024 · c7fdd5b · c7fdd5b
1 parent ec088cd
commit c7fdd5b
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 8 deletions.
diff --git a/nft_ingester/src/account_updates.rs b/nft_ingester/src/account_updates.rs
@@ -31,12 +31,15 @@ pub fn account_worker<T: Messenger>(
  tokio::spawn(async move {
  let source = T::new(config).await;
  if let Ok(mut msg) = source {
- let manager = Arc::new(ProgramTransformer::new(
- pool,
- create_download_metadata_notifier(bg_task_sender),
- false,
- false,
- ));
+ let manager = Arc::new(
+ ProgramTransformer::new(
+ pool,
+ create_download_metadata_notifier(bg_task_sender),
+ false,
+ false,
+ )
+ .await,
+ );
  loop {
  let e = msg.recv(stream_key, consumption_type.clone()).await;
  let mut tasks = JoinSet::new();

diff --git a/program_transformers/src/bubblegum/finalize_tree_with_root.rs b/program_transformers/src/bubblegum/finalize_tree_with_root.rs
@@ -25,7 +25,6 @@ where
  if let Some(batched_trees) = batched_trees {
  let mut b_trees = batched_trees.write().await;
  b_trees.insert(tree_id.clone());
- drop(b_trees);
  }
 
  let query = digital_asset_types::dao::batch_mint_to_verify::Entity::insert(

diff --git a/program_transformers/src/lib.rs b/program_transformers/src/lib.rs
@@ -228,7 +228,6 @@ impl ProgramTransformer {
  let batched_trees = batched_trees.read().await;
 
  if let Some(_tree) = batched_trees.get(&change_log.id) {
- drop(batched_trees);
  continue;
  }
  }