commit
448c0a950e
1 changed files with 2 additions and 2 deletions
|
@ -32,7 +32,7 @@ class AsyncPoller(object):
|
||||||
|
|
||||||
# flag to determine if at least one host was contacted
|
# flag to determine if at least one host was contacted
|
||||||
self.active = False
|
self.active = False
|
||||||
# True to work with & below
|
# True to work with the `and` below
|
||||||
skipped = True
|
skipped = True
|
||||||
jid = None
|
jid = None
|
||||||
for (host, res) in results['contacted'].iteritems():
|
for (host, res) in results['contacted'].iteritems():
|
||||||
|
@ -42,7 +42,7 @@ class AsyncPoller(object):
|
||||||
self.runner.vars_cache[host]['ansible_job_id'] = jid
|
self.runner.vars_cache[host]['ansible_job_id'] = jid
|
||||||
self.active = True
|
self.active = True
|
||||||
else:
|
else:
|
||||||
skipped = skipped & res.get('skipped', False)
|
skipped = skipped and res.get('skipped', False)
|
||||||
self.results['contacted'][host] = res
|
self.results['contacted'][host] = res
|
||||||
for (host, res) in results['dark'].iteritems():
|
for (host, res) in results['dark'].iteritems():
|
||||||
self.runner.vars_cache[host]['ansible_job_id'] = ''
|
self.runner.vars_cache[host]['ansible_job_id'] = ''
|
||||||
|
|
Loading…
Reference in a new issue