diff --git a/etcd/v3/kv_etcd.go b/etcd/v3/kv_etcd.go index f7462b9a..db3aba78 100644 --- a/etcd/v3/kv_etcd.go +++ b/etcd/v3/kv_etcd.go @@ -495,7 +495,7 @@ func (et *etcdKV) CompareAndSet( } // retry is needed // server timeout - kvPair, err := et.Get(kvp.Key) + kvPair, err := et.Get(key) if err != nil { return nil, txnErr } @@ -565,7 +565,7 @@ func (et *etcdKV) CompareAndDelete( } // retry is needed // server timeout - _, err := et.Get(kvp.Key) + _, err := et.Get(key) if err == kvdb.ErrNotFound { // Our command succeeded return kvp, nil