From 42f1a491c16f6c8737e5ea1ebdb8f93248db0e8e Mon Sep 17 00:00:00 2001 From: Wayne Witzel III Date: Wed, 9 Nov 2016 12:26:21 -0500 Subject: [PATCH] add WorkflowJob properties to UnifiedJob --- awx/main/models/unified_jobs.py | 10 ++++++++++ awx/main/models/workflow.py | 4 ++-- 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/awx/main/models/unified_jobs.py b/awx/main/models/unified_jobs.py index 520c8fe4de..b75b100d22 100644 --- a/awx/main/models/unified_jobs.py +++ b/awx/main/models/unified_jobs.py @@ -758,6 +758,16 @@ class UnifiedJob(PolymorphicModel, PasswordFieldsModel, CommonModelNameNotUnique def result_stdout_limited(self, start_line=0, end_line=None, redact_sensitive=False): return self._result_stdout_raw_limited(start_line, end_line, redact_sensitive, escape_ascii=True) + @property + def spawned_by_workflow(self): + return self.launch_type == 'workflow' + + @property + def workflow_job_id(self): + if self.spawned_by_workflow(): + return self.unified_job_node.workflow_job.pk + return None + @property def celery_task(self): try: diff --git a/awx/main/models/workflow.py b/awx/main/models/workflow.py index 426e2ac6b5..f51394afa3 100644 --- a/awx/main/models/workflow.py +++ b/awx/main/models/workflow.py @@ -185,9 +185,9 @@ class WorkflowJobTemplateNode(WorkflowNodeBase): return WorkflowJobNode.objects.create(**create_kwargs) class WorkflowJobNode(WorkflowNodeBase): - job = models.ForeignKey( + job = models.OneToOneField( 'UnifiedJob', - related_name='unified_job_nodes', + related_name='unified_job_node', blank=True, null=True, default=None,