Fixed one minor error

displague · Jan 7, 2020 · b275271 · b275271
1 parent f90bfae
commit b275271
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/db/workflow.go b/db/workflow.go
@@ -177,12 +177,13 @@ func insertActionList(ctx context.Context, db *sql.DB, yamlData string, id uuid.
 }
 
 // InsertIntoWfDataTable : Insert ephemeral data in workflow_data table
-func InsertIntoWfDataTable(ctx context.Context, db *sql.DB, req *pb.UpdateWorkflowDataRequest, index int) error {
+func InsertIntoWfDataTable(ctx context.Context, db *sql.DB, req *pb.UpdateWorkflowDataRequest) error {
 	version, err := getLatestVersionWfData(ctx, db, req.GetWorkflowID())
 	if err != nil {
 		return err
 	}
-
+	//increment the version
+	version = version + 1
 	tx, err := db.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelSerializable})
 	if err != nil {
 		return errors.Wrap(err, "BEGIN transaction")
@@ -205,7 +206,7 @@ func InsertIntoWfDataTable(ctx context.Context, db *sql.DB, req *pb.UpdateWorkfl
 	return nil
 }
 
-func GetfromWfDataTable(ctx context.Context, db *sql.DB, id string, changeIndex int) ([]byte, error) {
+func GetfromWfDataTable(ctx context.Context, db *sql.DB, id string) ([]byte, error) {
 
 	version, err := getLatestVersionWfData(ctx, db, id)
 	if err != nil {