notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/queue] Check for correct heartbeat interval

Browse source
This commit is contained in:
Laura Hausmann 2024-03-26 17:23:37 +01:00
parent a4ae25d5f3
commit c235f1a586
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
Iceshrimp.Backend/Core/Services/QueueService.cs
View file

@ -246,7 +246,7 @@ public class PostgresJobQueue<T>(
p.WorkerId != null && p.WorkerId != null &&
!db.Workers.Any(w => w.Id == p.WorkerId && !db.Workers.Any(w => w.Id == p.WorkerId &&
w.Heartbeat > w.Heartbeat >
DateTime.UtcNow - TimeSpan.FromSeconds(60)))), DateTime.UtcNow - TimeSpan.FromSeconds(45)))),
token); token);
var actualParallelism = Math.Min(parallelism - runningCount, queuedCount); var actualParallelism = Math.Min(parallelism - runningCount, queuedCount);