diff --git a/go/vt/wrangler/workflow.go b/go/vt/wrangler/workflow.go index 71317307185..0f429a9f532 100644 --- a/go/vt/wrangler/workflow.go +++ b/go/vt/wrangler/workflow.go @@ -324,7 +324,7 @@ func (vrw *VReplicationWorkflow) Complete() (*[]string, error) { renameTable = workflow.DropTable } if dryRunResults, err = vrw.wr.DropSources(vrw.ctx, vrw.ws.TargetKeyspace, vrw.ws.Workflow, renameTable, - false, vrw.params.KeepData, vrw.params.DryRun); err != nil { + vrw.params.KeepData, false /* force */, vrw.params.DryRun); err != nil { return nil, err } return dryRunResults, nil