mirror of
https://github.com/ansible/awx.git
synced 2026-02-20 12:40:06 -03:30
Propagate failed flag on job events to parent job events.
This commit is contained in:
@@ -1119,7 +1119,6 @@ class JobEvent(models.Model):
|
|||||||
|
|
||||||
def save(self, *args, **kwargs):
|
def save(self, *args, **kwargs):
|
||||||
self.failed = bool(self.event in self.FAILED_EVENTS)
|
self.failed = bool(self.event in self.FAILED_EVENTS)
|
||||||
# FIXME: Propagage failed flag to parent events.
|
|
||||||
try:
|
try:
|
||||||
if not self.host and self.event_data.get('host', ''):
|
if not self.host and self.event_data.get('host', ''):
|
||||||
self.host = self.job.inventory.hosts.get(name=self.event_data['host'])
|
self.host = self.job.inventory.hosts.get(name=self.event_data['host'])
|
||||||
@@ -1129,9 +1128,18 @@ class JobEvent(models.Model):
|
|||||||
self.task = self.event_data.get('task', '')
|
self.task = self.event_data.get('task', '')
|
||||||
self.parent = self._find_parent()
|
self.parent = self._find_parent()
|
||||||
super(JobEvent, self).save(*args, **kwargs)
|
super(JobEvent, self).save(*args, **kwargs)
|
||||||
|
self.update_parent_failed()
|
||||||
self.update_hosts()
|
self.update_hosts()
|
||||||
self.update_host_summary_from_stats()
|
self.update_host_summary_from_stats()
|
||||||
|
|
||||||
|
def update_parent_failed(self):
|
||||||
|
# Propagage failed flag to parent events.
|
||||||
|
if self.failed and self.parent and not self.parent.failed:
|
||||||
|
p = self.parent
|
||||||
|
p.failed = True
|
||||||
|
p.save()
|
||||||
|
p.update_parent_failed()
|
||||||
|
|
||||||
def update_hosts(self, extra_hosts=None):
|
def update_hosts(self, extra_hosts=None):
|
||||||
extra_hosts = extra_hosts or []
|
extra_hosts = extra_hosts or []
|
||||||
hostnames = set()
|
hostnames = set()
|
||||||
|
|||||||
Reference in New Issue
Block a user