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

fetch running workflow jobs once per process

Browse Source
This commit is contained in:
Wayne Witzel III
2018-08-02 11:29:30 -04:00
parent da603dd3ad
commit 74ed1c2c40
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -473,6 +473,7 @@ class TaskManager():
logger.debug(six.text_type("Dependent {} couldn't be scheduled on graph, waiting for next cycle").format(task.log_format)) logger.debug(six.text_type("Dependent {} couldn't be scheduled on graph, waiting for next cycle").format(task.log_format))
def process_pending_tasks(self, pending_tasks): def process_pending_tasks(self, pending_tasks):
running_workflow_templates = set([wf.workflow_job_template_id for wf in self.get_running_workflow_jobs()])
for task in pending_tasks: for task in pending_tasks:
self.process_dependencies(task, self.generate_dependencies(task)) self.process_dependencies(task, self.generate_dependencies(task))
if self.is_job_blocked(task): if self.is_job_blocked(task):
@@ -482,9 +483,7 @@ class TaskManager():
found_acceptable_queue = False found_acceptable_queue = False
idle_instance_that_fits = None idle_instance_that_fits = None
if isinstance(task, WorkflowJob): if isinstance(task, WorkflowJob):
running_workflow_templates = [wf.workflow_job_template_id for wf in self.get_running_workflow_jobs()] if task.workflow_job_template_id in running_workflow_templates:
running = task.workflow_job_template_id in running_workflow_templates
if running:
if not task.allow_simultaneous: if not task.allow_simultaneous:
logger.debug(six.text_type("{} is blocked from running, workflow already running").format(task.log_format)) logger.debug(six.text_type("{} is blocked from running, workflow already running").format(task.log_format))
continue continue