Merge pull request etcd-io#17249 from ahrtr/meta_bucket_20240115

Replace `CreateBucket` with `CreateBucketIfNotExists`
ahrtr · Jan 16, 2024 · e3c70c8 · e3c70c8
2 parents 4bc55e5 + 690916f
commit e3c70c8
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/server/storage/backend/batch_tx.go b/server/storage/backend/batch_tx.go
@@ -112,8 +112,7 @@ func (t *batchTx) Unlock() {
 }
 
 func (t *batchTx) UnsafeCreateBucket(bucket Bucket) {
-	_, err := t.tx.CreateBucket(bucket.Name())
-	if err != nil && err != bolt.ErrBucketExists {
+	if _, err := t.tx.CreateBucketIfNotExists(bucket.Name()); err != nil {
 		t.backend.lg.Fatal(
 			"failed to create a bucket",
 			zap.Stringer("bucket-name", bucket),