def METHOD_NAME(self):
    _TaipyLogger._get_logger().info("Start job dispatcher...")
    while not self._STOP_FLAG:
        try:
            if self._can_execute():
                with self.lock:
                    job = self.orchestrator.jobs_to_run.get(block=True, timeout=0.1)
                self._execute_job(job)
        except Exception:  # In case the last job of the queue has been removed.
            pass