summaryrefslogtreecommitdiff
path: root/tests/test_scheduler.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/test_scheduler.py')
-rw-r--r--tests/test_scheduler.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/tests/test_scheduler.py b/tests/test_scheduler.py
index 0cdcec4..684a076 100644
--- a/tests/test_scheduler.py
+++ b/tests/test_scheduler.py
@@ -198,8 +198,8 @@ class TestScheduler(RQTestCase):
pipeline.expire(locking_key_2, 1000)
scheduler.heartbeat()
- self.assertEqual(self.testconn.ttl(locking_key_1), 6)
- self.assertEqual(self.testconn.ttl(locking_key_1), 6)
+ self.assertEqual(self.testconn.ttl(locking_key_1), 61)
+ self.assertEqual(self.testconn.ttl(locking_key_1), 61)
# scheduler.stop() releases locks and sets status to STOPPED
scheduler._status = scheduler.Status.WORKING
@@ -213,7 +213,7 @@ class TestScheduler(RQTestCase):
scheduler.acquire_locks()
self.testconn.expire(locking_key_1, 1000)
scheduler.heartbeat()
- self.assertEqual(self.testconn.ttl(locking_key_1), 6)
+ self.assertEqual(self.testconn.ttl(locking_key_1), 61)
def test_enqueue_scheduled_jobs(self):
"""Scheduler can enqueue scheduled jobs"""