abort on write errors if failfast set

scylladb · Jun 19, 2019 · 70b6d33 · 70b6d33
1 parent a2b3b2c
commit 70b6d33
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cmd/gemini/root.go b/cmd/gemini/root.go
@@ -330,9 +330,9 @@ func runJob(f testJob, schema *gemini.Schema, s store.Store, mode string, out *o
 				if sp != nil {
 					sp.Suffix = fmt.Sprintf(" Running Gemini... %v", testRes)
 				}
-				if testRes.ReadErrors > 0 {
+				if testRes.ReadErrors > 0 || testRes.WriteErrors > 0 {
 					if failFast {
-						fmt.Println("Error in data validation. Exiting.")
+						fmt.Println("Errors detected. Exiting.")
 						stop(cancelWorkers, c, out, testRes)
 						return
 					}