diff --git a/go/logic/throttler.go b/go/logic/throttler.go
index 2535579ab..4fdf7f8f1 100644
--- a/go/logic/throttler.go
+++ b/go/logic/throttler.go
@@ -172,7 +172,7 @@ func (thlr *Throttler) collectReplicationLag(firstThrottlingCollected chan<- boo
 		if atomic.LoadInt64(&thlr.finishedMigrating) > 0 {
 			return
 		}
-		go collectFunc()
+		collectFunc()
 	}
 }