vmware · yonitoo · Mar 17, 2023 · Feb 24, 2023 · Feb 27, 2023 · Feb 27, 2023
diff --git a/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py b/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py
@@ -63,6 +63,10 @@ def execute_dag(self):
         while self._topological_sorter.is_active():
             for node in self._topological_sorter.get_ready():
                 self._start_job(node)
+                if len(self._job_executor.get_currently_running_jobs()) >= self._max_concurrent_running_jobs:
+                    finished_jobs = self._get_finished_jobs()
+                    self._finalize_jobs(finished_jobs)
+
             self._start_delayed_jobs()
 
             finished_jobs = self._get_finished_jobs()