rescue redis connection errors on job fetch

deanpcmad#75
Dynamics-Pay · Sep 13, 2016 · b546950 · b546950
1 parent d34a144
commit b546950
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/sidekiq/limit_fetch.rb b/lib/sidekiq/limit_fetch.rb
@@ -46,7 +46,7 @@ def redis_brpop(queues)
       sleep TIMEOUT  # there are no queues to handle, so lets sleep
       []             # and return nothing
     else
-      Sidekiq.redis { |it| it.brpop *queues, TIMEOUT }
+      redis_retryable { Sidekiq.redis { |it| it.brpop *queues, TIMEOUT } }
     end
   end
 end