ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Merge branch 'any-errors-fatal' of git://github.com/junegunn/ansible into devel

Browse source
This commit is contained in:
Michael DeHaan 2013-04-05 13:07:23 -04:00
commit b67cd6bbda
3 changed files with 16 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/ansible/playbook/__init__.py
View file

@ -63,7 +63,8 @@ class PlayBook(object):
subset = C.DEFAULT_SUBSET, subset = C.DEFAULT_SUBSET,
inventory = None, inventory = None,
check = False, check = False,
diff = False): diff = False,
any_errors_fatal = False):
""" """
playbook: path to a playbook file playbook: path to a playbook file
@ -113,6 +114,7 @@ class PlayBook(object):
self.global_vars = {} self.global_vars = {}
self.private_key_file = private_key_file self.private_key_file = private_key_file
self.only_tags = only_tags self.only_tags = only_tags
self.any_errors_fatal = any_errors_fatal
self.callbacks.playbook = self self.callbacks.playbook = self
self.runner_callbacks.playbook = self self.runner_callbacks.playbook = self
@ -447,6 +449,7 @@ class PlayBook(object):
self.inventory.also_restrict_to(on_hosts) self.inventory.also_restrict_to(on_hosts)
for task in play.tasks(): for task in play.tasks():
hosts_count = len(self._list_available_hosts(play.hosts))
# only run the task if the requested tags match # only run the task if the requested tags match
should_run = False should_run = False
@ -464,6 +467,9 @@ class PlayBook(object):
host_list = self._list_available_hosts(play.hosts) host_list = self._list_available_hosts(play.hosts)
if task.any_errors_fatal and len(host_list) < hosts_count:
host_list = None
# if no hosts remain, drop out # if no hosts remain, drop out
if not host_list: if not host_list:
self.callbacks.on_no_hosts_remaining() self.callbacks.on_no_hosts_remaining()

6
lib/ansible/playbook/play.py
View file

@ -30,7 +30,7 @@ class Play(object):
'handlers', 'remote_user', 'remote_port', 'handlers', 'remote_user', 'remote_port',
'sudo', 'sudo_user', 'transport', 'playbook', 'sudo', 'sudo_user', 'transport', 'playbook',
'tags', 'gather_facts', 'serial', '_ds', '_handlers', '_tasks', 'tags', 'gather_facts', 'serial', '_ds', '_handlers', '_tasks',
'basedir' 'basedir', 'any_errors_fatal'
] ]
# to catch typos and so forth -- these are userland names # to catch typos and so forth -- these are userland names
@ -38,7 +38,8 @@ class Play(object):
VALID_KEYS = [ VALID_KEYS = [
'hosts', 'name', 'vars', 'vars_prompt', 'vars_files', 'hosts', 'name', 'vars', 'vars_prompt', 'vars_files',
'tasks', 'handlers', 'user', 'port', 'include', 'tasks', 'handlers', 'user', 'port', 'include',
'sudo', 'sudo_user', 'connection', 'tags', 'gather_facts', 'serial' 'sudo', 'sudo_user', 'connection', 'tags', 'gather_facts', 'serial',
'any_errors_fatal'
] ]
# ************************************************* # *************************************************
@ -77,6 +78,7 @@ class Play(object):
self.gather_facts = ds.get('gather_facts', None) self.gather_facts = ds.get('gather_facts', None)
self.serial = int(utils.template(basedir, ds.get('serial', 0), self.vars)) self.serial = int(utils.template(basedir, ds.get('serial', 0), self.vars))
self.remote_port = utils.template(basedir, self.remote_port, self.vars) self.remote_port = utils.template(basedir, self.remote_port, self.vars)
self.any_errors_fatal = ds.get('any_errors_fatal', False)
self._update_vars_files_for_host(None) self._update_vars_files_for_host(None)

7
lib/ansible/playbook/task.py
View file

@ -27,7 +27,8 @@ class Task(object):
'play', 'notified_by', 'tags', 'register', 'play', 'notified_by', 'tags', 'register',
'delegate_to', 'first_available_file', 'ignore_errors', 'delegate_to', 'first_available_file', 'ignore_errors',
'local_action', 'transport', 'sudo', 'sudo_user', 'sudo_pass', 'local_action', 'transport', 'sudo', 'sudo_user', 'sudo_pass',
'items_lookup_plugin', 'items_lookup_terms', 'environment', 'args' 'items_lookup_plugin', 'items_lookup_terms', 'environment', 'args',
'any_errors_fatal'
] ]
# to prevent typos and such # to prevent typos and such
@ -35,7 +36,8 @@ class Task(object):
'name', 'action', 'only_if', 'async', 'poll', 'notify', 'name', 'action', 'only_if', 'async', 'poll', 'notify',
'first_available_file', 'include', 'tags', 'register', 'ignore_errors', 'first_available_file', 'include', 'tags', 'register', 'ignore_errors',
'delegate_to', 'local_action', 'transport', 'sudo', 'sudo_user', 'delegate_to', 'local_action', 'transport', 'sudo', 'sudo_user',
'sudo_pass', 'when', 'connection', 'environment', 'args' 'sudo_pass', 'when', 'connection', 'environment', 'args',
'any_errors_fatal'
] ]
def __init__(self, play, ds, module_vars=None, additional_conditions=None): def __init__(self, play, ds, module_vars=None, additional_conditions=None):
@ -151,6 +153,7 @@ class Task(object):
self.ignore_errors = ds.get('ignore_errors', False) self.ignore_errors = ds.get('ignore_errors', False)
self.any_errors_fatal = ds.get('any_errors_fatal', play.any_errors_fatal)
# action should be a string # action should be a string
if not isinstance(self.action, basestring): if not isinstance(self.action, basestring):