diff --git a/src/Hangfire.Raven/JobQueues/RavenJobQueue.cs b/src/Hangfire.Raven/JobQueues/RavenJobQueue.cs index 70f601b..b2af865 100644 --- a/src/Hangfire.Raven/JobQueues/RavenJobQueue.cs +++ b/src/Hangfire.Raven/JobQueues/RavenJobQueue.cs @@ -62,6 +62,7 @@ namespace Hangfire.Raven.JobQueues foreach (var job in repository.Query() .Where(fetchCondition) .Where(job => job.Queue == queue) + .Customize(x => x.WaitForNonStaleResultsAsOfNow()) .OfType()) { job.FetchedAt = DateTime.UtcNow;