|
|
@ -34,6 +34,7 @@ def to_nice_json(*a, **kw):
|
|
|
|
return json.dumps(*a, indent=4, sort_keys=True, **kw)
|
|
|
|
return json.dumps(*a, indent=4, sort_keys=True, **kw)
|
|
|
|
|
|
|
|
|
|
|
|
def failed(*a, **kw):
|
|
|
|
def failed(*a, **kw):
|
|
|
|
|
|
|
|
''' Test if task result yields failed '''
|
|
|
|
item = a[0]
|
|
|
|
item = a[0]
|
|
|
|
if type(item) != dict:
|
|
|
|
if type(item) != dict:
|
|
|
|
raise errors.AnsibleFilterError("|failed expects a dictionary")
|
|
|
|
raise errors.AnsibleFilterError("|failed expects a dictionary")
|
|
|
@ -45,9 +46,18 @@ def failed(*a, **kw):
|
|
|
|
return False
|
|
|
|
return False
|
|
|
|
|
|
|
|
|
|
|
|
def success(*a, **kw):
|
|
|
|
def success(*a, **kw):
|
|
|
|
|
|
|
|
''' Test if task result yields success '''
|
|
|
|
return not failed(*a, **kw)
|
|
|
|
return not failed(*a, **kw)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def changed(*a, **kw):
|
|
|
|
|
|
|
|
''' Test if task result yields changed '''
|
|
|
|
|
|
|
|
item = a[0]
|
|
|
|
|
|
|
|
if type(item) != dict:
|
|
|
|
|
|
|
|
raise errors.AnsibleFilterError("|changed expects a dictionary")
|
|
|
|
|
|
|
|
return item.get('changed', False)
|
|
|
|
|
|
|
|
|
|
|
|
def skipped(*a, **kw):
|
|
|
|
def skipped(*a, **kw):
|
|
|
|
|
|
|
|
''' Test if task result yields skipped '''
|
|
|
|
item = a[0]
|
|
|
|
item = a[0]
|
|
|
|
if type(item) != dict:
|
|
|
|
if type(item) != dict:
|
|
|
|
raise errors.AnsibleFilterError("|skipped expects a dictionary")
|
|
|
|
raise errors.AnsibleFilterError("|skipped expects a dictionary")
|
|
|
@ -106,6 +116,9 @@ class FilterModule(object):
|
|
|
|
'failed' : failed,
|
|
|
|
'failed' : failed,
|
|
|
|
'success' : success,
|
|
|
|
'success' : success,
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# changed testing
|
|
|
|
|
|
|
|
'changed' : changed,
|
|
|
|
|
|
|
|
|
|
|
|
# skip testing
|
|
|
|
# skip testing
|
|
|
|
'skipped' : skipped,
|
|
|
|
'skipped' : skipped,
|
|
|
|
|
|
|
|
|
|
|
|