diff --git a/internal/db/kvs/bbolt/bbolt.go b/internal/db/kvs/bbolt/bbolt.go index 78cb6c4b96..e5c9b0fb7d 100644 --- a/internal/db/kvs/bbolt/bbolt.go +++ b/internal/db/kvs/bbolt/bbolt.go @@ -53,7 +53,7 @@ func New(file, bucket string, mode fs.FileMode, opts *bolt.Options) (Bbolt, erro } if err := db.Update(func(tx *bolt.Tx) error { - _, err := tx.CreateBucket(bk) + _, err := tx.CreateBucketIfNotExists(bk) if err != nil { return fmt.Errorf("failed to create bucket: %w", err) }