Hangfire DistributedLockTimeoutException при одновременном вызове одного и того же статического метода ⇐ C#

[Anonymous]

У меня есть веб-сервис, который при публикации ставит в очередь загрузку изображений в 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)


Подробнее здесь: https://stackoverflow.com/questions/417 ... method-con