return error for txn condition not succeeded

Author: jschwinger233

store/etcdv3/workload.go

@@ -278,15 +278,22 @@ func (m *Mercury) doOpsWorkload(ctx context.Context, workload *types.Workload, p
 		filepath.Join(workloadDeployPrefix, appname, entrypoint, workload.Nodename, workload.ID): workloadData,
 	}
 
+	var resp *clientv3.TxnResponse
 	if create {
 		if processing != nil {
 			processingKey := m.getProcessingKey(processing)
 			err = m.BatchCreateAndDecr(ctx, data, processingKey)
 		} else {
-			_, err = m.BatchCreate(ctx, data)
+			resp, err = m.BatchCreate(ctx, data)
 		}
 	} else {
-		_, err = m.BatchUpdate(ctx, data)
+		resp, err = m.BatchUpdate(ctx, data)
 	}
-	return err
+	if err != nil {
+		return err
+	}
+	if !resp.Succeeded {
+		return types.ErrTxnConditionFailed
+	}
+	return nil
 }

types/errors.go

@@ -66,10 +66,11 @@ var (
 	ErrRunAndWaitCountOneWithStdin = errors.New("Count must be 1 if OpenStdin is true")
 	ErrUnknownControlType          = errors.New("Unknown control type")
 
-	ErrNoETCD       = errors.New("ETCD must be set")
-	ErrKeyNotExists = errors.New("Key not exists")
-	ErrKeyExists    = errors.New("Key exists")
-	ErrNoOps        = errors.New("No txn ops")
+	ErrNoETCD             = errors.New("ETCD must be set")
+	ErrKeyNotExists       = errors.New("Key not exists")
+	ErrKeyExists          = errors.New("Key exists")
+	ErrNoOps              = errors.New("No txn ops")
+	ErrTxnConditionFailed = errors.New("ETCD Txn condition failed")
 
 	ErrNotSupport = errors.New("Not Support")
 	ErrSCMNotSet  = errors.New("SCM not set")