Don't ignore a duplicate host for an already processed include (#40361)

* Don't ignore a duplicate host for an already processed include, assume that the repetition indicates a new include. Fixes #40317

* Add intg tests to ensure duplicate items in loop are not deduped

* Add note about relative indexing
This commit is contained in:
Matt Martz 2018-06-08 15:36:22 -05:00 committed by GitHub
parent 77b54a3267
commit 76867730bf
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 36 additions and 6 deletions

View file

@ -44,6 +44,8 @@ class IncludedFile:
def add_host(self, host): def add_host(self, host):
if host not in self._hosts: if host not in self._hosts:
self._hosts.append(host) self._hosts.append(host)
return
raise ValueError()
def __eq__(self, other): def __eq__(self, other):
return other._filename == self._filename and other._args == self._args and other._task._parent._uuid == self._task._parent._uuid return other._filename == self._filename and other._args == self._args and other._task._parent._uuid == self._task._parent._uuid
@ -160,12 +162,24 @@ class IncludedFile:
inc_file = IncludedFile(role_name, include_variables, new_task, is_role=True) inc_file = IncludedFile(role_name, include_variables, new_task, is_role=True)
try: idx = 0
pos = included_files.index(inc_file) orig_inc_file = inc_file
inc_file = included_files[pos] while 1:
except ValueError: try:
included_files.append(inc_file) pos = included_files[idx:].index(orig_inc_file)
# pos is relative to idx since we are slicing
# use idx + pos due to relative indexing
inc_file = included_files[idx + pos]
except ValueError:
included_files.append(orig_inc_file)
inc_file = orig_inc_file
inc_file.add_host(original_host) try:
inc_file.add_host(original_host)
except ValueError:
# The host already exists for this include, advance forward, this is a new include
idx += pos + 1
else:
break
return included_files return included_files

View file

@ -73,3 +73,9 @@ if [[ -z "$OUT" ]]; then
echo "apply on import_tasks did not cause error" echo "apply on import_tasks did not cause error"
exit 1 exit 1
fi fi
# Test that duplicate items in loop are not deduped
ANSIBLE_STRATEGY='linear' ansible-playbook tasks/test_include_dupe_loop.yml -i ../../inventory "$@" | tee test_include_dupe_loop.out
test "$(grep -c 'item=foo' test_include_dupe_loop.out)" = 3
ANSIBLE_STRATEGY='free' ansible-playbook tasks/test_include_dupe_loop.yml -i ../../inventory "$@" | tee test_include_dupe_loop.out
test "$(grep -c 'item=foo' test_include_dupe_loop.out)" = 3

View file

@ -0,0 +1,2 @@
- debug:
msg: "item={{ item }}"

View file

@ -0,0 +1,8 @@
- name: Test Include Duplicate Loop Items
hosts: testhost
tasks:
- include_tasks: debug_item.yml
loop:
- foo
- foo
- foo