diff options
| author | James Cammarata <jimi@sngx.net> | 2016-05-17 14:06:10 -0400 |
|---|---|---|
| committer | James Cammarata <jimi@sngx.net> | 2016-05-18 08:17:53 -0400 |
| commit | 710a96956eaece69ff9cfb6381801b1994897348 (patch) | |
| tree | b132b1db0bdb916d8285f506a7ccc1240f069663 | |
| parent | 7855612805351a50d17406c36e826e98742af44c (diff) | |
| download | ansible-710a96956eaece69ff9cfb6381801b1994897348.tar.gz | |
In TQM run() mark any entries in _failed_hosts as failed in the PlayIterator
As noted in the comment, the TQM may be used for more than one play. As such,
after creating the new PlayIterator object it is necessary to mark any failed
hosts from previous calls to run() as failed in the iterator, so they are
properly skipped during any future calls to run().
| -rw-r--r-- | lib/ansible/executor/task_queue_manager.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/lib/ansible/executor/task_queue_manager.py b/lib/ansible/executor/task_queue_manager.py index c2592f0f34..ba4970ed66 100644 --- a/lib/ansible/executor/task_queue_manager.py +++ b/lib/ansible/executor/task_queue_manager.py @@ -236,6 +236,13 @@ class TaskQueueManager: start_at_done = self._start_at_done, ) + # because the TQM may survive multiple play runs, we start by + # marking any hosts as failed in the iterator here which may + # have been marked as failed in previous runs. + for host_name in self._failed_hosts.keys(): + host = self._inventory.get_host(host_name) + iterator.mark_host_failed(host) + # during initialization, the PlayContext will clear the start_at_task # field to signal that a matching task was found, so check that here # and remember it so we don't try to skip tasks on future plays |