def METHOD_NAME(self):
    logger.info("Requeuing stalled jobs.")
    for job in self.storage.get_running_jobs():
        logger.info("Requeuing job id {}.".format(job.job_id))
        self.storage.mark_job_as_queued(job.job_id)