def METHOD_NAME(self):
    while (
        len(self._job_executor.get_currently_running_jobs())
        < self._max_concurrent_running_jobs
    ):
        job = self._delayed_starting_jobs.dequeue()
        if job is None:
            break
        log.info(f"Trying to start job {job} again.")
        self._start_job(job)