Remove status check for metadata update queue watching

ppy · Jan 6, 2025 · c8ee9fb · c8ee9fb
1 parent 4b0f072
commit c8ee9fb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/osu.Server.Spectator/Database/DatabaseAccess.cs b/osu.Server.Spectator/Database/DatabaseAccess.cs
@@ -292,7 +292,7 @@ public async Task<BeatmapUpdates> GetUpdatedBeatmapSets(int? lastQueueId, int li
 
             if (lastQueueId.HasValue)
             {
-                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE status = 2 AND queue_id > @lastQueueId LIMIT @limit", new
+                var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE queue_id > @lastQueueId LIMIT @limit", new
                 {
                     lastQueueId,
                     limit
@@ -301,7 +301,7 @@ public async Task<BeatmapUpdates> GetUpdatedBeatmapSets(int? lastQueueId, int li
                 return new BeatmapUpdates(items.Select(i => i.beatmapset_id).ToArray(), items.LastOrDefault()?.queue_id ?? lastQueueId.Value);
             }
 
-            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE status = 2 ORDER BY queue_id DESC LIMIT 1");
+            var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
 
             return new BeatmapUpdates(Array.Empty<int>(), lastEntry?.queue_id ?? 0);
         }