From bf89093fac00c30624688a15202ca4afe76468c1 Mon Sep 17 00:00:00 2001 From: Elijah DeLee Date: Mon, 11 Jul 2022 10:26:04 -0400 Subject: [PATCH] unify call pattern for get_tasks --- awx/main/scheduler/task_manager.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index 790cd04c05..810b830594 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -275,12 +275,12 @@ class WorkflowManager(TaskBase): task.save(update_fields=['status', 'job_explanation', 'timed_out']) @timeit - def get_tasks(self): - self.all_tasks = [wf for wf in WorkflowJob.objects.filter(status='running')] + def get_tasks(self, filter_args): + self.all_tasks = [wf for wf in WorkflowJob.objects.filter(**filter_args)] @timeit def _schedule(self): - self.get_tasks() + self.get_tasks(dict(status__in=["running"], dependencies_processed=True)) if len(self.all_tasks) > 0: self.spawn_workflow_graph_jobs() self.timeout_approval_node()