summaryrefslogtreecommitdiff
path: root/tests/test_queue.py
diff options
context:
space:
mode:
authorAlexey Katichev <aleksey.katichev@gmail.com>2017-05-22 14:31:22 +0300
committerAlexey Katichev <aleksey.katichev@gmail.com>2017-05-22 14:31:22 +0300
commit09697e567f18590e31f8faad3c2f71e7b2f41659 (patch)
tree1da1863b566396c7a6099849b1404d5a5b5052ce /tests/test_queue.py
parentb7d50cedc4a83c81825bc51aa0518cd17c4e3e63 (diff)
downloadrq-09697e567f18590e31f8faad3c2f71e7b2f41659.tar.gz
revert back job.cleanup changes
Diffstat (limited to 'tests/test_queue.py')
-rw-r--r--tests/test_queue.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/tests/test_queue.py b/tests/test_queue.py
index 3eea3fb..7129452 100644
--- a/tests/test_queue.py
+++ b/tests/test_queue.py
@@ -654,9 +654,10 @@ class TestFailedQueue(RQTestCase):
def test_job_in_failed_queue_persists(self):
"""Make sure failed job key does not expire"""
q = Queue('foo')
- job = q.enqueue(div_by_zero, args=(1, 2, 3), ttl=5)
+ job = q.enqueue(div_by_zero, args=(1,), ttl=5)
self.assertEqual(self.testconn.ttl(job.key), 5)
-
+
+ self.assertRaises(ZeroDivisionError, job.perform)
job.set_status(JobStatus.FAILED)
failed_queue = get_failed_queue()
failed_queue.quarantine(job, Exception('Some fake error'))