diff options
| author | Alexey Katichev <aleksey.katichev@gmail.com> | 2017-05-07 16:57:12 +0300 |
|---|---|---|
| committer | Alexey Katichev <aleksey.katichev@gmail.com> | 2017-05-07 16:57:12 +0300 |
| commit | 3596449cc0bf2e51809cfe09d0ab9fca522775db (patch) | |
| tree | 2d6bd5d6dc81a857b201a0e9a78dca61848e64b5 /tests/test_queue.py | |
| parent | fbe4cafe2a0433b1919abb3292e4c2e60bc17852 (diff) | |
| download | rq-3596449cc0bf2e51809cfe09d0ab9fca522775db.tar.gz | |
remove implicit cleanup call from job.save
Diffstat (limited to 'tests/test_queue.py')
| -rw-r--r-- | tests/test_queue.py | 12 |
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) |
