diff --git a/pkg/cannon/deriver/beacon/eth/v1/beacon_validators.go b/pkg/cannon/deriver/beacon/eth/v1/beacon_validators.go index 4a131ec4..d97e504a 100644 --- a/pkg/cannon/deriver/beacon/eth/v1/beacon_validators.go +++ b/pkg/cannon/deriver/beacon/eth/v1/beacon_validators.go @@ -31,7 +31,8 @@ const ( ) type BeaconValidatorsDeriverConfig struct { - Enabled bool `yaml:"enabled" default:"true"` + Enabled bool `yaml:"enabled" default:"true"` + ChunkSize int `yaml:"chunkSize" default:"100"` } type BeaconValidatorsDeriver struct { @@ -240,8 +241,8 @@ func (b *BeaconValidatorsDeriver) processEpoch(ctx context.Context, epoch phase0 validatorsMap := validatorsResponse.Data - // Chunk the validators per 1000 - chunkSize := 1000 + // Chunk the validators per the configured chunk size + chunkSize := b.cfg.ChunkSize var validatorChunks [][]*apiv1.Validator