External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-07 17:37:37 -02:30
Code Issues Packages Projects Releases Wiki Activity

unify call pattern for get_tasks

Browse Source
This commit is contained in:
Elijah DeLee
2022-07-11 10:26:04 -04:00
committed by Seth Foster
parent 76d76d13b0
commit bf89093fac
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/scheduler/task_manager.py
View File

@@ -275,12 +275,12 @@ class WorkflowManager(TaskBase):
task.save(update_fields=['status', 'job_explanation', 'timed_out']) task.save(update_fields=['status', 'job_explanation', 'timed_out'])
@timeit @timeit
def get_tasks(self): def get_tasks(self, filter_args):
self.all_tasks = [wf for wf in WorkflowJob.objects.filter(status='running')] self.all_tasks = [wf for wf in WorkflowJob.objects.filter(**filter_args)]
@timeit @timeit
def _schedule(self): def _schedule(self):
self.get_tasks() self.get_tasks(dict(status__in=["running"], dependencies_processed=True))
if len(self.all_tasks) > 0: if len(self.all_tasks) > 0:
self.spawn_workflow_graph_jobs() self.spawn_workflow_graph_jobs()
self.timeout_approval_node() self.timeout_approval_node()