diff --git a/validator_client/validator_services/src/sync.rs b/validator_client/validator_services/src/sync.rs index 73e4c69d71..4e2d3b4571 100644 --- a/validator_client/validator_services/src/sync.rs +++ b/validator_client/validator_services/src/sync.rs @@ -520,8 +520,15 @@ pub async fn fill_in_aggregation_proofs( "pre_compute_slot" => pre_compute_slot ); + let slots_to_process = if duties_service.distributed { + vec![current_slot] + } else { + (current_slot.as_u64()..=pre_compute_slot.as_u64()) + .map(Slot::new) + .collect::>() + }; // Generate selection proofs for each validator at each slot, one slot at a time. - for slot in (current_slot.as_u64()..=pre_compute_slot.as_u64()).map(Slot::new) { + for slot in slots_to_process { let mut validator_proofs = vec![]; for (validator_start_slot, duty) in pre_compute_duties { // Proofs are already known at this slot for this validator.