diff --git a/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Performance/Scores/UpdateAllScoresCommand.cs b/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Performance/Scores/UpdateAllScoresCommand.cs
index 5b82d0f3..a3cf6624 100644
--- a/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Performance/Scores/UpdateAllScoresCommand.cs
+++ b/osu.Server.Queues.ScoreStatisticsProcessor/Commands/Performance/Scores/UpdateAllScoresCommand.cs
@@ -78,6 +78,9 @@ protected override async Task<int> ExecuteAsync(CancellationToken cancellationTo
                 {
                     using (var connection = DatabaseAccess.GetConnection())
                         await SlaveLatencyChecker.CheckSlaveLatency(connection, cancellationToken);
+
+                    if (cancellationToken.IsCancellationRequested)
+                        break;
                 }
 
                 sw.Restart();