make batchupdate idempotent

Author: jschwinger233

store/etcdv3/meta/etcd.go

@@ -308,7 +308,7 @@ func (e *ETCD) Grant(ctx context.Context, ttl int64) (*clientv3.LeaseGrantRespon
 func (e *ETCD) batchUpdate(ctx context.Context, data map[string]string, opts ...clientv3.OpOption) (*clientv3.TxnResponse, error) {
 	limit := map[string]map[string]string{}
 	for key := range data {
-		limit[key] = map[string]string{cmpVersion: "!=", cmpValue: "!="} // ignore same data
+		limit[key] = map[string]string{cmpVersion: "!="}
 	}
 	resp, err := e.batchPut(ctx, data, limit, opts...)
 	if err != nil {

store/etcdv3/node_test.go

@@ -205,7 +205,7 @@ func TestUpdateNode(t *testing.T) {
 		},
 	}
 	assert.Error(t, m.UpdateNodes(ctx, fakeNode))
-	assert.Error(t, m.UpdateNodes(ctx, node), "ETCD Txn condition failed")
+	assert.NoError(t, m.UpdateNodes(ctx, node))
 	node.Available = false
 	assert.NoError(t, m.UpdateNodes(ctx, node))
 }

store/etcdv3/workload_test.go

@@ -36,7 +36,7 @@ func TestAddORUpdateWorkload(t *testing.T) {
 	assert.NoError(t, err)
 	// success updat
 	err = m.UpdateWorkload(ctx, workload)
-	assert.Error(t, err, "ETCD Txn condition failed")
+	assert.NoError(t, err)
 	// success updat
 	workload.Name = "test_app_2"
 	err = m.UpdateWorkload(ctx, workload)