Use trx lag

Signed-off-by: Matt Lord <[email protected]>
vitessio · Jan 23, 2025 · 9fb48f7 · 9fb48f7
1 parent 4e8e109
commit 9fb48f7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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() {