def METHOD_NAME(self):
    while not self.orchestrator.jobs_to_run.empty():
        with self.lock:
            try:
                job = self.orchestrator.jobs_to_run.get()
            except Exception:  # In case the last job of the queue has been removed.
                self.__logger.warning(f"{job.id} is no longer in the list of jobs to run.")
        self._execute_job(job)