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

use workflow_template_id

Browse Source
This commit is contained in:
Wayne Witzel III
2018-08-01 15:55:19 -04:00
parent c96cf3cf5d
commit da603dd3ad
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

@@ -482,11 +482,11 @@ 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.pk for wf in self.get_running_workflow_jobs()] running_workflow_templates = [wf.workflow_job_template_id for wf in self.get_running_workflow_jobs()]
running = task.workflow_job_template.pk in running_workflow_templates running = task.workflow_job_template_id in running_workflow_templates
if running: 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, task.workflow_job_template.pk)) logger.debug(six.text_type("{} is blocked from running, workflow already running").format(task.log_format))
continue continue
self.start_task(task, None, task.get_jobs_fail_chain(), None) self.start_task(task, None, task.get_jobs_fail_chain(), None)
continue continue