diff --git a/go/libraries/doltcore/env/actions/dolt_ci/workflow_manager.go b/go/libraries/doltcore/env/actions/dolt_ci/workflow_manager.go
index 3dee1c7d92..6b907693a4 100644
--- a/go/libraries/doltcore/env/actions/dolt_ci/workflow_manager.go
+++ b/go/libraries/doltcore/env/actions/dolt_ci/workflow_manager.go
@@ -632,12 +632,10 @@ func (d *doltWorkflowManager) sqlReadQuery(ctx *sql.Context, query string, cb fu
 
 	size := len(sch)
 	for _, row := range rows {
-
 		cvs := make(columnValues, size)
-
-		for i := range size {
+		for i := range sch {
 			col := sch[i]
-			val := row[i]
+			val := row.GetValue(i)
 			cv, err := newColumnValue(col, val)
 			if err != nil {
 				return err