report

Signed-off-by: lhy1024 <[email protected]>
lhy1024 · Jan 22, 2025 · 51f54a4 · 51f54a4
1 parent 577b1cc
commit 51f54a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/storage/kv/etcd_kv.go b/pkg/storage/kv/etcd_kv.go
@@ -210,7 +210,7 @@ type etcdTxn struct {
 func (kv *etcdKVBase) RunInTxn(ctx context.Context, f func(txn Txn) error) error {
 	txn := &etcdTxn{
 		kv:  kv,
-		ctx: ctx,
+		ctx: clientv3.WithRequireLeader(ctx),
 	}
 	err := f(txn)
 	if err != nil {