diff --git a/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs b/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
index 9ffdc50..069c9a7 100644
--- a/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
+++ b/osu.Server.QueueProcessor/BeatmapStatusWatcher.cs
@@ -56,7 +56,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue
 
             if (lastQueueId.HasValue)
             {
-                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new
+                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue WHERE queue_id > @lastQueueId ORDER BY queue_id LIMIT @limit", new
                 {
                     lastQueueId,
                     limit
@@ -69,7 +69,7 @@ public static async Task<BeatmapUpdates> GetUpdatedBeatmapSetsAsync(int? lastQue
                 };
             }
 
-            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
+            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT queue_id, beatmapset_id FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
 
             return new BeatmapUpdates
             {