ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-07-26 22:51:23 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Abort a play when there are no more hosts in it.

Browse source
This commit is contained in:
Michael DeHaan 2012-09-30 20:48:35 -04:00
commit 19b78cedc8
1 changed files with 26 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -235,7 +235,14 @@ class PlayBook(object):
# if not polling, playbook requested fire and forget, so don't poll # if not polling, playbook requested fire and forget, so don't poll
results = self._async_poll(poller, task.async_seconds, task.async_poll_interval) results = self._async_poll(poller, task.async_seconds, task.async_poll_interval)
contacted = results.get('contacted',{})
dark = results.get('dark', {})
self.inventory.lift_restriction() self.inventory.lift_restriction()
if len(contacted.keys()) == 0 and len(dark.keys()) == 0:
return None
return results return results
# ***************************************************** # *****************************************************
@ -247,14 +254,18 @@ class PlayBook(object):
# load up an appropriate ansible runner to run the task in parallel # load up an appropriate ansible runner to run the task in parallel
results = self._run_task_internal(task) results = self._run_task_internal(task)
# if no hosts are matched, carry on # if no hosts are matched, carry on
hosts_remaining = True
if results is None: if results is None:
hosts_remaining = False
results = {} results = {}
contacted = results.get('contacted', {})
self.stats.compute(results, ignore_errors=task.ignore_errors) self.stats.compute(results, ignore_errors=task.ignore_errors)
# add facts to the global setup cache # add facts to the global setup cache
for host, result in results['contacted'].iteritems(): for host, result in contacted.iteritems():
facts = result.get('ansible_facts', {}) facts = result.get('ansible_facts', {})
self.SETUP_CACHE[host].update(facts) self.SETUP_CACHE[host].update(facts)
if task.register: if task.register:
@ -269,6 +280,8 @@ class PlayBook(object):
for handler_name in task.notify: for handler_name in task.notify:
self._flag_handler(play.handlers(), utils.template(play.basedir, handler_name, task.module_vars), host) self._flag_handler(play.handlers(), utils.template(play.basedir, handler_name, task.module_vars), host)
return hosts_remaining
# ***************************************************** # *****************************************************
def _flag_handler(self, handlers, handler_name, host): def _flag_handler(self, handlers, handler_name, host):
@ -347,11 +360,16 @@ class PlayBook(object):
play_hosts.append(all_hosts.pop()) play_hosts.append(all_hosts.pop())
serialized_batch.append(play_hosts) serialized_batch.append(play_hosts)
hosts_remaining = True
for on_hosts in serialized_batch: for on_hosts in serialized_batch:
self.inventory.also_restrict_to(on_hosts) self.inventory.also_restrict_to(on_hosts)
for task in play.tasks(): for task in play.tasks():
if not hosts_remaining:
continue
# only run the task if the requested tags match # only run the task if the requested tags match
should_run = False should_run = False
for x in self.only_tags: for x in self.only_tags:
@ -360,10 +378,13 @@ class PlayBook(object):
should_run = True should_run = True
break break
if should_run: if should_run:
self._run_task(play, task, False) if not self._run_task(play, task, False):
hosts_remaining = False
# run notify actions # run notify actions
for handler in play.handlers(): for handler in play.handlers():
if not hosts_remaining:
continue
if len(handler.notified_by) > 0: if len(handler.notified_by) > 0:
self.inventory.restrict_to(handler.notified_by) self.inventory.restrict_to(handler.notified_by)
self._run_task(play, handler, True) self._run_task(play, handler, True)