code: def enqueue_jobs(self):
          
          self.log.debug('Checking for scheduled jobs')
  
          jobs = self.get_jobs_to_queue()
          for job in jobs:
              self.enqueue_job(job)
  
          # Refresh scheduler key's expiry
          self.connection.expire(self.scheduler_key, int(self._interval) + 10)
          return jobs
docs: Move scheduled jobs into queues.