summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorSelwin Ong <selwin.ong@gmail.com>2019-03-15 21:32:29 +0700
committerSelwin Ong <selwin.ong@gmail.com>2019-03-15 21:32:29 +0700
commit6e6e42521ad5c5f53d726cc5423b8102e5424ae5 (patch)
tree42023f7b98a99a13b88aa31800be7a7fe14a7cad /tests
parentf963d46a572a1deee4117c0f666766b3ce89fbcd (diff)
downloadrq-deprecate-timeout.tar.gz
queue.enqueue() no longer accepts `timeout` argumentdeprecate-timeout
Diffstat (limited to 'tests')
-rw-r--r--tests/test_queue.py11
1 files changed, 4 insertions, 7 deletions
diff --git a/tests/test_queue.py b/tests/test_queue.py
index 16a0e04..62a8f11 100644
--- a/tests/test_queue.py
+++ b/tests/test_queue.py
@@ -328,19 +328,16 @@ class TestQueue(RQTestCase):
def test_job_timeout(self):
"""Timeout can be passed via job_timeout argument"""
queue = Queue()
- job = queue.enqueue(echo, 1, timeout=15)
- self.assertEqual(job.timeout, 15)
-
job = queue.enqueue(echo, 1, job_timeout=15)
self.assertEqual(job.timeout, 15)
-
+
def test_default_timeout(self):
"""Timeout can be passed via job_timeout argument"""
queue = Queue()
job = queue.enqueue(echo, 1)
self.assertEqual(job.timeout, queue.DEFAULT_TIMEOUT)
-
- job = Job.create(func=echo)
+
+ job = Job.create(func=echo)
job = queue.enqueue_job(job)
self.assertEqual(job.timeout, queue.DEFAULT_TIMEOUT)
@@ -348,7 +345,7 @@ class TestQueue(RQTestCase):
job = queue.enqueue(echo, 1)
self.assertEqual(job.timeout, 15)
- job = Job.create(func=echo)
+ job = Job.create(func=echo)
job = queue.enqueue_job(job)
self.assertEqual(job.timeout, 15)