Skip to content

Commit 63bb290

Browse files
authored
Merge pull request #254 from peppy/remove-queue-status-check
Remove status check for metadata update queue watching
2 parents 4b0f072 + c8ee9fb commit 63bb290

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

osu.Server.Spectator/Database/DatabaseAccess.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ public async Task<BeatmapUpdates> GetUpdatedBeatmapSets(int? lastQueueId, int li
292292

293293
if (lastQueueId.HasValue)
294294
{
295-
var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE status = 2 AND queue_id > @lastQueueId LIMIT @limit", new
295+
var items = (await connection.QueryAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE queue_id > @lastQueueId LIMIT @limit", new
296296
{
297297
lastQueueId,
298298
limit
@@ -301,7 +301,7 @@ public async Task<BeatmapUpdates> GetUpdatedBeatmapSets(int? lastQueueId, int li
301301
return new BeatmapUpdates(items.Select(i => i.beatmapset_id).ToArray(), items.LastOrDefault()?.queue_id ?? lastQueueId.Value);
302302
}
303303

304-
var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue WHERE status = 2 ORDER BY queue_id DESC LIMIT 1");
304+
var lastEntry = await connection.QueryFirstOrDefaultAsync<bss_process_queue_item>("SELECT * FROM bss_process_queue ORDER BY queue_id DESC LIMIT 1");
305305

306306
return new BeatmapUpdates(Array.Empty<int>(), lastEntry?.queue_id ?? 0);
307307
}

0 commit comments

Comments
 (0)