Requeue each delayed job that are now ready to be executed

def requeue_delayed_jobs(self):
        """
        Requeue each delayed job that are now ready to be executed
        """
        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)