Fix waitForWorkflowToBeCreated

Signed-off-by: Matt Lord <mattalord@gmail.com>
planetscale · Dec 28, 2024 · 85c87ff · 85c87ff
1 parent dd72a3c
commit 85c87ff
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/go/test/endtoend/vreplication/helper_test.go b/go/test/endtoend/vreplication/helper_test.go
@@ -348,7 +348,7 @@ func waitForWorkflowToBeCreated(t *testing.T, vc *VitessCluster, ksWorkflow stri
 	keyspace, workflow := parseKeyspaceWorkflow(t, ksWorkflow)
 	require.NoError(t, waitForCondition("workflow to be created", func() bool {
 		output, err := vc.VtctldClient.ExecuteCommandWithOutput("Workflow", "--keyspace", keyspace, "show", "--workflow", workflow, "--compact", "--include-logs=false")
-		return err == nil && isEmptyWorkflowShowOutput(output)
+		return err == nil && !isEmptyWorkflowShowOutput(output)
 	}, defaultTimeout))
 }
 
@@ -1082,9 +1082,8 @@ func isEmptyWorkflowShowOutput(output string) bool {
 		emptyJSON                           = `{}`
 		emptyNonCompactWorkflowShowResponse = `{
   "workflows": []
-}
-`
+}`
 	)
 
-	return output == emptyJSON || output == emptyNonCompactWorkflowShowResponse
+	return strings.TrimSpace(output) == emptyJSON || strings.TrimSpace(output) == emptyNonCompactWorkflowShowResponse
 }