def METHOD_NAME(self):
    """
    Execute the DAG of jobs.
    :return:
    """
    self._topological_sorter.prepare()
    while self._topological_sorter.is_active():
        for node in self._topological_sorter.get_ready():
            self._start_job(node)
        self._start_delayed_jobs()
        finished_jobs = self._get_finished_jobs()
        self._finalize_jobs(finished_jobs)
        if not finished_jobs:
            # No jobs are finished at this iteration so let's wait a bit to let them
            # finish
            time.sleep(self._dag_execution_check_time_period_seconds)