Get rid of process_tasks we did not need

ansible · Mar 31, 2023 · 4c7330c · 4c7330c
1 parent df2c842
commit 4c7330c
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py
@@ -369,18 +369,15 @@ def generate_dependencies(self, undeped_tasks):
 
         return dependencies
 
-    def process_tasks(self):
-        deps = self.generate_dependencies(self.all_tasks)
-        undeped_deps = [dep for dep in deps if dep.dependencies_processed is False]
-        self.generate_dependencies(undeped_deps)
-        self.subsystem_metrics.inc(f"{self.prefix}_pending_processed", len(self.all_tasks) + len(undeped_deps))
-
     @timeit
     def _schedule(self):
         self.get_tasks(dict(status__in=["pending"], dependencies_processed=False))
 
         if len(self.all_tasks) > 0:
-            self.process_tasks()
+            deps = self.generate_dependencies(self.all_tasks)
+            undeped_deps = [dep for dep in deps if dep.dependencies_processed is False]
+            self.generate_dependencies(undeped_deps)
+            self.subsystem_metrics.inc(f"{self.prefix}_pending_processed", len(self.all_tasks) + len(undeped_deps))
             ScheduleTaskManager().schedule()