diff --git a/go/vt/vtctl/reparentutil/emergency_reparenter.go b/go/vt/vtctl/reparentutil/emergency_reparenter.go index 105bdde91ad..3dfb3e64e4b 100644 --- a/go/vt/vtctl/reparentutil/emergency_reparenter.go +++ b/go/vt/vtctl/reparentutil/emergency_reparenter.go @@ -379,11 +379,11 @@ func (erp *EmergencyReparenter) waitForAllRelayLogsToApply( continue } - go func(alias string) { + go func(alias string, status *replicationdatapb.StopReplicationStatus) { var err error defer func() { errCh <- err }() err = WaitForRelayLogsToApply(groupCtx, erp.tmc, tabletMap[alias], status) - }(candidate) + }(candidate, status) waiterCount++ }