Skip to content

Commit

Permalink
Update pkg/throttler/mysql80replica.go
Browse files Browse the repository at this point in the history
Co-authored-by: Morgan Tocker <[email protected]>
  • Loading branch information
prudhvi and morgo authored Jul 30, 2024
1 parent 5db36de commit 781f798
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/throttler/mysql80replica.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ func (l *MySQL80Replica) UpdateLag() error {
}
atomic.StoreInt64(&l.currentLagInMs, newLagValue)
if l.IsThrottled() {
l.logger.Warnf("replication delayed, throttling in progress. lag: %v tolerance: %v",
l.logger.Warnf("replication delayed, throttling in progress. lag: %v tolerance: %v",
atomic.LoadInt64(&l.currentLagInMs), l.lagTolerance)
}
return nil
Expand Down

0 comments on commit 781f798

Please sign in to comment.