[backend/queue] Only raise a job queued event for the first matching queue when retrying a job

This commit is contained in:
Laura Hausmann 2024-06-28 18:01:26 +02:00
parent 0e6edb9046
commit 6ba374a681
No known key found for this signature in database
GPG key ID: D044E84C5BE01605

View file

@ -254,8 +254,7 @@ public class QueueService(
.SetProperty(i => i.ExceptionSource, _ => null)
.SetProperty(i => i.StackTrace, _ => null));
if (cnt <= 0) return;
foreach (var queue in _queues.Where(p => p.Name == job.Queue))
queue.RaiseJobQueuedEvent();
_queues.FirstOrDefault(p => p.Name == job.Queue)?.RaiseJobQueuedEvent();
}
}
}