From 6b7688abaa09c89a8c41a2359adbeceb8f26a390 Mon Sep 17 00:00:00 2001 From: Rohit Nayak Date: Tue, 30 Jul 2024 17:18:42 +0200 Subject: [PATCH] Cleanup reference test Signed-off-by: Rohit Nayak --- go/vt/vtctl/workflow/stream_migrator_test.go | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/go/vt/vtctl/workflow/stream_migrator_test.go b/go/vt/vtctl/workflow/stream_migrator_test.go index ffae171199d..5e9c2a79038 100644 --- a/go/vt/vtctl/workflow/stream_migrator_test.go +++ b/go/vt/vtctl/workflow/stream_migrator_test.go @@ -544,24 +544,6 @@ func addReferenceWorkflow(t *testing.T, env *streamMigratorEnv, id int32, source for _, resp := range workflowResponses { env.tenv.tmc.AddVReplicationWorkflowsResponse(workflowKey, resp) } - for _, id := range env.sourceTabletIds { - queries := []string{ - fmt.Sprintf("select distinct vrepl_id from _vt.copy_state where vrepl_id in (%d)", id), - fmt.Sprintf("update _vt.vreplication set state='Stopped', message='for cutover' where id in (%d)", id), - } - for _, q := range queries { - env.tenv.tmc.expectVRQuery(id, q, &sqltypes.Result{}) - } - } - for _, id := range env.targetTabletIds { - queries := []string{ - fmt.Sprintf("delete from _vt.vreplication where db_name='vt_%s' and workflow in ('%s')", - env.tenv.targetKeyspace.KeyspaceName, wfName), - } - for _, q := range queries { - env.tenv.tmc.expectVRQuery(id, q, &sqltypes.Result{}) - } - } } func TestBuildStreamMigratorOneMaterialize(t *testing.T) {