From 33ca6c77a342d03cd3ebe0edbed5a8204ea57a64 Mon Sep 17 00:00:00 2001 From: ykadowak Date: Fri, 8 Sep 2023 09:11:40 +0000 Subject: [PATCH] increase eg limit to the MaxBatchSize --- internal/cache/bbolt/bbolt.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/cache/bbolt/bbolt.go b/internal/cache/bbolt/bbolt.go index 43318c5efc9..174a98feee8 100644 --- a/internal/cache/bbolt/bbolt.go +++ b/internal/cache/bbolt/bbolt.go @@ -50,7 +50,7 @@ func (b *Bbolt) Set(key string, val []byte) error { func (b *Bbolt) SetBatch(kv map[string]struct{}) error { eg, _ := errgroup.WithContext(context.Background()) - eg.SetLimit(200) + eg.SetLimit(b.db.MaxBatchSize) for k := range kv { key := k eg.Go(func() error {