File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
crates/engine/tree/src/tree/payload_processor Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -707,9 +707,10 @@ impl MultiProofTask {
707707 // Process proof targets in chunks.
708708 let mut chunks = 0 ;
709709
710- // Only chunk if account workers are available to take advantage of parallelism.
710+ // Only chunk if account or storage workers are available to take advantage of parallelism.
711711 let should_chunk =
712- self . multiproof_manager . proof_worker_handle . has_available_account_workers ( ) ;
712+ self . multiproof_manager . proof_worker_handle . has_available_account_workers ( ) ||
713+ self . multiproof_manager . proof_worker_handle . has_available_storage_workers ( ) ;
713714
714715 let mut spawn = |proof_targets| {
715716 self . multiproof_manager . spawn (
@@ -847,9 +848,10 @@ impl MultiProofTask {
847848
848849 let mut spawned_proof_targets = MultiProofTargets :: default ( ) ;
849850
850- // Only chunk if account workers are available to take advantage of parallelism.
851+ // Only chunk if account or storage workers are available to take advantage of parallelism.
851852 let should_chunk =
852- self . multiproof_manager . proof_worker_handle . has_available_account_workers ( ) ;
853+ self . multiproof_manager . proof_worker_handle . has_available_account_workers ( ) ||
854+ self . multiproof_manager . proof_worker_handle . has_available_storage_workers ( ) ;
853855
854856 let mut spawn = |hashed_state_update| {
855857 let proof_targets = get_proof_targets (
You can’t perform that action at this time.
0 commit comments