cap connection wait time at 60

rq · Jan 9, 2021 · 704083d · 704083d
1 parent bd42136
commit 704083d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rq/worker.py b/rq/worker.py
@@ -598,6 +598,7 @@ def dequeue_job_and_maintain_ttl(self, timeout):
                                conn_err, connection_wait_time)
                 time.sleep(connection_wait_time)
                 connection_wait_time *= self.exponential_backoff_factor
+                connection_wait_time = min(connection_wait_time, 60)
             else:
                 connection_wait_time = 1.0