From 9fb48f794538785cd4457631bfc010c7f214c318 Mon Sep 17 00:00:00 2001 From: Matt Lord Date: Thu, 23 Jan 2025 04:23:41 +0000 Subject: [PATCH] Use trx lag Signed-off-by: Matt Lord --- go/vt/vtctl/workflow/server.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/go/vt/vtctl/workflow/server.go b/go/vt/vtctl/workflow/server.go index 732e798bc04..ad2009da2a8 100644 --- a/go/vt/vtctl/workflow/server.go +++ b/go/vt/vtctl/workflow/server.go @@ -3069,8 +3069,8 @@ func (s *Server) canSwitch(ctx context.Context, ts *trafficSwitcher, maxAllowedR if err != nil { return "", err } - if wf.MaxVReplicationLag > maxAllowedReplLagSecs { - return fmt.Sprintf(cannotSwitchHighLag, wf.MaxVReplicationLag, maxAllowedReplLagSecs), nil + if wf.MaxVReplicationTransactionLag > maxAllowedReplLagSecs { + return fmt.Sprintf(cannotSwitchHighLag, wf.MaxVReplicationTransactionLag, maxAllowedReplLagSecs), nil } for _, stream := range wf.ShardStreams { for _, st := range stream.GetStreams() {