summaryrefslogtreecommitdiff
path: root/tests/test_queue.py
diff options
context:
space:
mode:
authorAlexey Katichev <aleksey.katichev@gmail.com>2017-05-07 16:57:12 +0300
committerAlexey Katichev <aleksey.katichev@gmail.com>2017-05-07 16:57:12 +0300
commit3596449cc0bf2e51809cfe09d0ab9fca522775db (patch)
tree2d6bd5d6dc81a857b201a0e9a78dca61848e64b5 /tests/test_queue.py
parentfbe4cafe2a0433b1919abb3292e4c2e60bc17852 (diff)
downloadrq-3596449cc0bf2e51809cfe09d0ab9fca522775db.tar.gz
remove implicit cleanup call from job.save
Diffstat (limited to 'tests/test_queue.py')
-rw-r--r--tests/test_queue.py12
1 files changed, 12 insertions, 0 deletions
diff --git a/tests/test_queue.py b/tests/test_queue.py
index 294fb62..3eea3fb 100644
--- a/tests/test_queue.py
+++ b/tests/test_queue.py
@@ -650,3 +650,15 @@ class TestFailedQueue(RQTestCase):
job.delete()
self.assertFalse(job.id in failed_queue.get_job_ids())
+
+ 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)
+ self.assertEqual(self.testconn.ttl(job.key), 5)
+
+ job.set_status(JobStatus.FAILED)
+ failed_queue = get_failed_queue()
+ failed_queue.quarantine(job, Exception('Some fake error'))
+
+ self.assertEqual(self.testconn.ttl(job.key), -1)