wbrawner/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

improved output in with_items fixes: #627

Browse source
This commit is contained in:
Derek Carter 2012-07-20 14:01:54 -04:00
parent 8bb8314d10
commit 34e2584220
2 changed files with 30 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
lib/ansible/callbacks.py
View file

@ -248,27 +248,50 @@ class PlaybookRunnerCallbacks(DefaultRunnerCallbacks):
def on_unreachable(self, host, msg):
print "fatal: [%s] => %s" % (host, msg)
item = msg.get('item', None)
if item:
print "fatal: [%s] => (item=%s) => %s" % (host, item, msg)
else:
print "fatal: [%s] => %s" % (host, msg)
def on_failed(self, host, results):
print "failed: [%s] => %s" % (host, utils.jsonify(results))
item = results.get('item', None)
if item:
print "failed: [%s] => (item=%s) => %s" % (host, item, utils.jsonify(results))
else:
print "failed: [%s] => %s" % (host, utils.jsonify(results))
def on_ok(self, host, host_result):
item = host_result.get('item', None)
# show verbose output for non-setup module results if --verbose is used
if not self.verbose or host_result.get("verbose_override",None) is not None:
print "ok: [%s]" % (host)
if item:
print "ok: [%s] => (item=%s)" % (host,item)
else:
print "ok: [%s]" % (host)
else:
print "ok: [%s] => %s" % (host, utils.jsonify(host_result))
if item:
print "ok: [%s] => (item=%s) => %s" % (host, item, utils.jsonify(host_result))
else:
print "ok: [%s] => %s" % (host, utils.jsonify(host_result))
def on_error(self, host, err):
print >>sys.stderr, "err: [%s] => %s" % (host, err)
item = err.get('item', None)
if item:
print >>sys.stderr, "err: [%s] => (item=%s) => %s" % (host, item, err)
else:
print >>sys.stderr, "err: [%s] => %s" % (host, err)
def on_skipped(self, host):
print "skipping: [%s]" % host
print "skipping: [%s]" % host
def on_no_hosts(self):

1
lib/ansible/runner/__init__.py
View file

@ -645,6 +645,7 @@ class Runner(object):
self.callbacks.on_unreachable(host, result.result)
else:
data = result.result
result.result['item'] = inject.get('item', None)
if 'skipped' in data:
self.callbacks.on_skipped(result.host)
elif not result.is_successful():