Support for specifying item label in a loop (#17294)
This commit is contained in:
parent
61e7c3af1a
commit
f65a3ce547
3 changed files with 9 additions and 0 deletions
|
@ -234,9 +234,11 @@ class TaskExecutor:
|
|||
task_vars = self._job_vars
|
||||
|
||||
loop_var = 'item'
|
||||
label = None
|
||||
if self._task.loop_control:
|
||||
# the value may be 'None', so we still need to default it back to 'item'
|
||||
loop_var = self._task.loop_control.loop_var or 'item'
|
||||
label = self._task.loop_control.label or ('{{' + loop_var + '}}')
|
||||
|
||||
if loop_var in task_vars:
|
||||
display.warning("The loop variable '%s' is already in use. You should set the `loop_var` value in the `loop_control` option for the task to something else to avoid variable collisions and unexpected behavior." % loop_var)
|
||||
|
@ -266,6 +268,10 @@ class TaskExecutor:
|
|||
res[loop_var] = item
|
||||
res['_ansible_item_result'] = True
|
||||
|
||||
if not label is None:
|
||||
templar = Templar(loader=self._loader, shared_loader_obj=self._shared_loader_obj, variables=self._job_vars)
|
||||
res['_ansible_item_label'] = templar.template(label, fail_on_undefined=False)
|
||||
|
||||
self._rslt_q.put(TaskResult(self._host.name, self._task._uuid, res), block=False)
|
||||
results.append(res)
|
||||
del task_vars[loop_var]
|
||||
|
|
|
@ -29,6 +29,7 @@ from ansible.playbook.base import Base
|
|||
class LoopControl(Base):
|
||||
|
||||
_loop_var = FieldAttribute(isa='str')
|
||||
_label = FieldAttribute(isa='str')
|
||||
|
||||
def __init__(self):
|
||||
super(LoopControl, self).__init__()
|
||||
|
|
|
@ -174,6 +174,8 @@ class CallbackBase:
|
|||
def _get_item(self, result):
|
||||
if result.get('_ansible_no_log', False):
|
||||
item = "(censored due to no_log)"
|
||||
elif result.get('_ansible_item_label', False):
|
||||
item = result.get('_ansible_item_label')
|
||||
else:
|
||||
item = result.get('item', None)
|
||||
|
||||
|
|
Loading…
Reference in a new issue