diff --git a/crates/node-core/src/node_config.rs b/crates/node-core/src/node_config.rs index c58cc4b9f804..ba16640f86ec 100644 --- a/crates/node-core/src/node_config.rs +++ b/crates/node-core/src/node_config.rs @@ -462,6 +462,7 @@ impl NodeConfig { let validator = TransactionValidationTaskExecutor::eth_builder(Arc::clone(&self.chain)) .with_head_timestamp(head.timestamp) .kzg_settings(self.kzg_settings()?) + // use an additional validation task so we can validate transactions in parallel .with_additional_tasks(1) .build_with_tasks(blockchain_db.clone(), executor.clone(), blob_store.clone()); diff --git a/crates/transaction-pool/src/validate/task.rs b/crates/transaction-pool/src/validate/task.rs index cc50277bfd07..58801fcac3e5 100644 --- a/crates/transaction-pool/src/validate/task.rs +++ b/crates/transaction-pool/src/validate/task.rs @@ -18,6 +18,10 @@ use tokio::{ use tokio_stream::wrappers::ReceiverStream; /// A service that performs validation jobs. +/// +/// This listens for incoming validation jobs and executes them. +/// +/// This should be spawned as a task: [ValidationTask::run] #[derive(Clone)] pub struct ValidationTask { #[allow(clippy::type_complexity)]