У меня есть веб-сервис, который при публикации ставит в очередь загрузку изображений в Hangfire, поэтому в случае сбоя загрузки изображения Hangfire автоматически повторяет попытку:
[AutomaticRetry(Attempts = 5, OnAttemptsExceeded = AttemptsExceededAction.Delete)]
public static void DownloadImage(string url)
{
...
}
Каждый раз, когда веб-сервис публикуется, он добавляет несколько фоновых заданий, которые вызывают этот метод следующим образом:
Hangfire.BackgroundJob.Enqueue(() => Downloader.DownloadImage(o.SourceURL));
Однако я вижу, что первое из фоновых заданий завершается успешно, а остальные терпят неудачу в БЫСТРОЙ последовательности, т.е. менее чем за секунду, скажем, 100 заданий в очереди не будут выделены 5 раз (согласно атрибуту AutomaticRetry).
Ошибка в задачах Hangfire:
Hangfire.Storage.DistributedLockTimeoutException
Timeout expired. The timeout elapsed prior to obtaining a distributed lock on the 'HangFire:Downloader.DownloadImage' resource.
Hangfire.Storage.DistributedLockTimeoutException: Timeout expired. The timeout elapsed prior to obtaining a distributed lock on the 'HangFire:Downloader.DownloadImage' resource.
at Hangfire.SqlServer.SqlServerDistributedLock.Acquire(IDbConnection connection, String resource, TimeSpan timeout)
at Hangfire.SqlServer.SqlServerDistributedLock..ctor(SqlServerStorage storage, String resource, TimeSpan timeout)
at Hangfire.SqlServer.SqlServerConnection.AcquireDistributedLock(String resource, TimeSpan timeout)
at Hangfire.DisableConcurrentExecutionAttribute.OnPerforming(PerformingContext filterContext)
at Hangfire.Server.BackgroundJobPerformer.InvokePerformFilter(IServerFilter filter, PerformingContext preContext, Func`1 continuation)
