diff --git a/core/node/node_framework/src/implementations/layers/commitment_generator.rs b/core/node/node_framework/src/implementations/layers/commitment_generator.rs index 5d2f2d47678b..aeb668dca178 100644 --- a/core/node/node_framework/src/implementations/layers/commitment_generator.rs +++ b/core/node/node_framework/src/implementations/layers/commitment_generator.rs @@ -30,7 +30,8 @@ impl WiringLayer for CommitmentGeneratorLayer { async fn wire(self: Box, mut context: ServiceContext<'_>) -> Result<(), WiringError> { let pool_resource = context.get_resource::>().await?; - let main_pool = pool_resource.get().await?; + let pool_size = CommitmentGenerator::default_parallelism().get(); + let main_pool = pool_resource.get_custom(pool_size).await?; let commitment_generator = CommitmentGenerator::new(main_pool, self.mode);