Run replay in spawn_fifo to avoid clogging main runtime

FuelLabs · Feb 12, 2025 · aaaa57b · aaaa57b
1 parent 0a1b16a
commit aaaa57b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/crates/services/producer/src/block_producer.rs b/crates/services/producer/src/block_producer.rs
@@ -400,8 +400,11 @@ where
     ) -> anyhow::Result<Vec<StorageReadReplayEvent>> {
         let view = self.view_provider.latest_view()?;
 
+        let executor = self.executor.clone();
         let block = view.get_full_block(&height)?;
-        Ok(self.executor.storage_read_replay(&block)?)
+
+        // use the blocking threadpool to avoid clogging up the main async runtime
+        tokio_rayon::spawn_fifo(move || Ok(executor.storage_read_replay(&block)?)).await
     }
 }