openstack
/
tripleo-ansible
Code Issues Proposed changes

Merge "Allow any_errors_fatal to be dynamic"

This commit is contained in:
Zuul 2020-07-21 01:32:14 +00:00 committed by Gerrit Code Review
parent 77bd1a910b 28d4e52a16
commit 7ffb084b2a
3 changed files with 30 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tripleo_ansible/ansible_plugins/strategy/tripleo_base.py
View File

@ -127,6 +127,14 @@ class TripleoBase(StrategyBase):
failures[role] = 1
return failures
def _get_task_errors_fatal(self, task, templar):
"""Return parsed any_errors_fatal from a task"""
return task.get_validated_value('any_errors_fatal',
task._valid_attrs['any_errors_fatal'],
templar.template(
task.any_errors_fatal),
None)
def process_includes(self, host_results, noop=False):
"""Handle includes

2
tripleo_ansible/ansible_plugins/strategy/tripleo_free.py
View File

@ -227,7 +227,7 @@ class StrategyModule(BASE.TripleoBase):
self._blocked_hosts[host_name] = False
else:
if not self._step or self._take_step(task, host_name):
if task.any_errors_fatal:
if self._get_task_errors_fatal(task, templar):
display.warning('any_errors_fatal only stops any future '
'tasks running on the host that fails '
'with the tripleo_free strategy.')

40
tripleo_ansible/ansible_plugins/strategy/tripleo_linear.py
View File

@ -214,6 +214,25 @@ class StrategyModule(BASE.TripleoBase):
and not task._role._metadata.allow_duplicates):
raise TripleoLinearNoHostTask()
# todo handle steps like in linear
# build get_vars call params
vars_params = {'play': self._iterator._play,
'host': host,
'task': task}
# if we have >= 2.9 we can use the hosts cache
if self._has_hosts_cache:
vars_params['_hosts'] = self._hosts_cache
if self._has_hosts_cache_all:
vars_params['_hosts_all'] = self._hosts_cache_all
task_vars = self._variable_manager.get_vars(**vars_params)
self.add_tqm_variables(task_vars, play=self._iterator._play)
templar = Templar(loader=self._loader, variables=task_vars)
run_once = (templar.template(task.run_once) or action
and getattr(action, 'BYPASS_HOST_LOOP', False))
if task.action == 'meta':
results.extend(self._execute_meta(task,
self._play_context,
@ -223,27 +242,10 @@ class StrategyModule(BASE.TripleoBase):
'reset_connection',
'end_host')):
run_once = True
if (task.any_errors_fatal or run_once and not task.ignore_errors):
if (self._get_task_errors_fatal(task, templar)
or run_once and not task.ignore_errors):
self._any_errors_fatal = True
else:
# todo handle steps like in linear
# build get_vars call params
vars_params = {'play': self._iterator._play,
'host': host,
'task': task}
# if we have >= 2.9 we can use the hosts cache
if self._has_hosts_cache:
vars_params['_hosts'] = self._hosts_cache
if self._has_hosts_cache_all:
vars_params['_hosts_all'] = self._hosts_cache_all
task_vars = self._variable_manager.get_vars(**vars_params)
self.add_tqm_variables(task_vars, play=self._iterator._play)
templar = Templar(loader=self._loader, variables=task_vars)
run_once = (templar.template(task.run_once) or action
and getattr(action, 'BYPASS_HOST_LOOP', False))
self._send_task_callback(task, templar)
self._blocked_hosts[host.get_name()] = True
self._queue_task(host, task, task_vars, self._play_context)