Fix - Use worker TTL for timeout (#1794)

* Use worker TTL for timeout

* add test

* renames

* test

* use dequeue_timeout

1 files changed, 10 insertions, 0 deletions

diff --git a/tests/test_worker.py b/tests/test_worker.py
index b0bb3d7..cfce473 100644
--- a/tests/test_worker.py
+++ b/tests/test_worker.py
@@ -642,6 +642,16 @@ class TestWorker(RQTestCase):
         # Put it on the queue with a timeout value
         self.assertIsNone(w.dequeue_job_and_maintain_ttl(None))
 
+    def test_worker_ttl_param_resolves_timeout(self):
+        """Ensures the worker_ttl param is being considered in the dequeue_timeout and connection_timeout params, takes into account 15 seconds gap (hard coded)"""
+        q = Queue()
+        w = Worker([q])
+        self.assertEqual(w.dequeue_timeout, 405)
+        self.assertEqual(w.connection_timeout, 415)
+        w = Worker([q], default_worker_ttl=500)
+        self.assertEqual(w.dequeue_timeout, 485)
+        self.assertEqual(w.connection_timeout, 495)
+
     def test_worker_sets_result_ttl(self):
         """Ensure that Worker properly sets result_ttl for individual jobs."""
         q = Queue()