From 7faca0534442cfa8815ef63e4aa701e562d77b0b Mon Sep 17 00:00:00 2001 From: Georgios Konstantopoulos Date: Tue, 24 Feb 2026 03:07:19 -0800 Subject: [PATCH] refactor(engine): use spawn_blocking_named for tx_iterator thread (#22522) Co-authored-by: Amp --- crates/engine/tree/src/tree/payload_processor/mod.rs | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/crates/engine/tree/src/tree/payload_processor/mod.rs b/crates/engine/tree/src/tree/payload_processor/mod.rs index fd91184058..66047c7943 100644 --- a/crates/engine/tree/src/tree/payload_processor/mod.rs +++ b/crates/engine/tree/src/tree/payload_processor/mod.rs @@ -416,9 +416,7 @@ where transaction_count, "using sequential sig recovery for small block" ); - self.executor.spawn_blocking(move || { - let _enter = - debug_span!(target: "engine::tree::payload_processor", "tx_iterator").entered(); + self.executor.spawn_blocking_named("tx-iterator", move || { let (transactions, convert) = transactions.into_parts(); convert_serial(transactions.into_iter(), &convert, &prewarm_tx, &execute_tx); }); @@ -430,9 +428,7 @@ where // few transactions are recovered sequentially and sent immediately before // entering the parallel iterator for the remainder. let prefetch = Self::PARALLEL_PREFETCH_COUNT.min(transaction_count); - self.executor.spawn_blocking(move || { - let _enter = - debug_span!(target: "engine::tree::payload_processor", "tx_iterator").entered(); + self.executor.spawn_blocking_named("tx-iterator", move || { let (transactions, convert) = transactions.into_parts(); let mut all: Vec<_> = transactions.into_iter().collect(); let rest = all.split_off(prefetch.min(all.len()));