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

[backend/core] Call RaiseJobQueuedEvent in QueueService.DelayedJobsHandler (ISH-229)

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

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

@ -225,7 +225,11 @@ public class PostgresJobQueue<T>(
.ExecuteUpdateAsync(p => p.SetProperty(i => i.Status, i => Job.JobStatus.Queued),
token);
if (count > 0) continue;
if (count > 0)
{
await RaiseJobQueuedEvent(db);
continue;
}
var tokenSource = new CancellationTokenSource();
await ScheduleDelayedEvent(tokenSource.Token);