Merge pull request #2789 from AlanCoding/running_wfjts

Add current workflow job to running list
This commit is contained in:
Wayne Witzel III
2018-08-08 08:47:07 -04:00
committed by GitHub

View File

@@ -496,6 +496,8 @@ class TaskManager():
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
else:
running_workflow_templates.add(task.workflow_job_template_id)
self.start_task(task, None, task.get_jobs_fail_chain(), None) self.start_task(task, None, task.get_jobs_fail_chain(), None)
continue continue
for rampart_group in preferred_instance_groups: for rampart_group in preferred_instance_groups: