From 4f987a67a60bb2b54299b7029e7ccf8ad1663627 Mon Sep 17 00:00:00 2001 From: Matt Lord Date: Thu, 4 Apr 2024 15:36:13 -0400 Subject: [PATCH] Missed a couple of spots Signed-off-by: Matt Lord --- go/test/endtoend/vreplication/wrappers_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/go/test/endtoend/vreplication/wrappers_test.go b/go/test/endtoend/vreplication/wrappers_test.go index 58fca102bab..fee98eaf3d7 100644 --- a/go/test/endtoend/vreplication/wrappers_test.go +++ b/go/test/endtoend/vreplication/wrappers_test.go @@ -92,7 +92,7 @@ func newVtctlMoveTables(mt *moveTables) *VtctlMoveTables { func (vmt *VtctlMoveTables) Create() { log.Infof("vmt is %+v", vmt.vc, vmt.tables) - err := tstWorkflowExec(vmt.vc.t, "", vmt.workflowName, vmt.sourceKeyspace, vmt.targetKeyspace, + err := tstWorkflowExecVtctl(vmt.vc.t, "", vmt.workflowName, vmt.sourceKeyspace, vmt.targetKeyspace, vmt.tables, workflowActionCreate, "", vmt.sourceShards, "", vmt.atomicCopy) require.NoError(vmt.vc.t, err) } @@ -125,7 +125,7 @@ func (vmt *VtctlMoveTables) SwitchWrites() { } func (vmt *VtctlMoveTables) Cancel() { - err := tstWorkflowExec(vmt.vc.t, "", vmt.workflowName, vmt.sourceKeyspace, vmt.targetKeyspace, + err := tstWorkflowExecVtctl(vmt.vc.t, "", vmt.workflowName, vmt.sourceKeyspace, vmt.targetKeyspace, vmt.tables, workflowActionCancel, "", "", "", vmt.atomicCopy) require.NoError(vmt.vc.t, err) }