diff --git a/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs b/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
index 069c9a7..c1882df 100644
--- a/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
+++ b/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
@@ -64,7 +64,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue
 
                 return new BeatmapUpdates
                 {
-                    BeatmapSetIDs = items.Select(i => i.beatmapset_id).ToArray(),
+                    BeatmapSetIDs = items.Select(i => i.beatmapset_id).Distinct().ToArray(),
                     LastProcessedQueueID = items.LastOrDefault()?.queue_id ?? lastQueueId.Value
                 };
             }