diff --git a/nft_ingester/src/account_updates.rs b/nft_ingester/src/account_updates.rs
index b807d045..8799da33 100644
--- 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
index f6badaee..96ef47cb 100644
--- 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
index db649ec4..215ff193 100644
--- 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;
                                 }
                             }