diff --git a/db/bigtable.go b/db/bigtable.go index 89d8f1f7e1..9def14e9fc 100644 --- a/db/bigtable.go +++ b/db/bigtable.go @@ -1130,7 +1130,7 @@ func (bigtable *Bigtable) GetValidatorAttestationHistory(validators []uint64, st res := make(map[uint64][]*types.ValidatorAttestation, len(validators)) resMux := &sync.Mutex{} - filter := gcp_bigtable.LatestNFilter(1) + filter := gcp_bigtable.LatestNFilter(32) g, gCtx := errgroup.WithContext(ctx) g.SetLimit(concurrency) @@ -1421,7 +1421,7 @@ func (bigtable *Bigtable) GetValidatorMissedAttestationHistory(validators []uint resMux := &sync.Mutex{} - filter := gcp_bigtable.LatestNFilter(1) + filter := gcp_bigtable.LatestNFilter(32) g, gCtx := errgroup.WithContext(ctx) g.SetLimit(concurrency)