Replace one more unsafe predicate usage and fix unit tests

Signed-off-by: Matt Lord <mattalord@gmail.com>
vitessio · Dec 18, 2023 · 385e9fe · 385e9fe
1 parent 0507f64
commit 385e9fe
Show file tree

Hide file tree

Showing 5 changed files with 74 additions and 74 deletions.
diff --git a/go/vt/vtctl/workflow/stream_migrator.go b/go/vt/vtctl/workflow/stream_migrator.go
@@ -199,8 +199,8 @@ func (sm *StreamMigrator) StopStreams(ctx context.Context) ([]string, error) {
 /* tablet streams */
 
 func (sm *StreamMigrator) readTabletStreams(ctx context.Context, ti *topo.TabletInfo, constraint string) ([]*VReplicationStream, error) {
-	query := fmt.Sprintf("select id, workflow, source, pos, workflow_type, workflow_sub_type, defer_secondary_keys from _vt.vreplication where db_name=%s and workflow != %s",
-		encodeString(ti.DbName()), encodeString(sm.ts.ReverseWorkflowName()))
+	query := fmt.Sprintf("select id, workflow, source, pos, workflow_type, workflow_sub_type, defer_secondary_keys from _vt.vreplication where db_name=%s and workflow=%s",
+		encodeString(ti.DbName()), encodeString(sm.ts.WorkflowName()))
 	if constraint != "" {
 		query += fmt.Sprintf(" and %s", constraint)
 	}