def METHOD_NAME(self):
    """Expired jobs should also be retried"""
    queue = Queue(connection=self.testconn)
    registry = StartedJobRegistry(connection=self.testconn)
    failed_job_registry = FailedJobRegistry(connection=self.testconn)
    job = queue.enqueue(say_hello, retry=Retry(max=1))
    # Add job to StartedJobRegistry with past expiration time
    self.testconn.zadd(registry.key, {job.id: 2})
    registry.cleanup()
    self.assertEqual(len(queue), 2)
    self.assertEqual(job.get_status(), JobStatus.QUEUED)
    self.assertNotIn(job, failed_job_registry)
    self.testconn.zadd(registry.key, {job.id: 2})
    # Job goes to FailedJobRegistry because it's only retried once
    registry.cleanup()
    self.assertEqual(len(queue), 2)
    self.assertEqual(job.get_status(), JobStatus.FAILED)
    self.assertIn(job, failed_job_registry)