code: def requeue_delayed_jobs(self):
          
          failures = []
          for queue in self.queue_model.get_all_by_priority(self.queues):
              failures.extend(queue.requeue_delayed_jobs())
  
          self.last_requeue_delayed = datetime.utcnow()
  
          for failure in failures:
              self.log('Unable to requeue %s: %s' % failure)
docs: Requeue each delayed job that are now ready to be executed