ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Merge pull request #143 from jhoekx/fix-ansible-async

Browse source 
/bin/ansible async fixes
This commit is contained in:
Michael DeHaan 2012-04-13 07:18:23 -07:00
commit aaecf70586
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
bin/ansible
View file

@ -147,6 +147,8 @@ class Cli(object):
clock = clock - options.poll_interval clock = clock - options.poll_interval
time.sleep(options.poll_interval) time.sleep(options.poll_interval)
poll_hosts = self.hosts_to_poll(poll_results) poll_hosts = self.hosts_to_poll(poll_results)
if len(poll_hosts)==0:
break
######################################################## ########################################################

2
lib/ansible/runner.py
View file

@ -119,7 +119,7 @@ class Runner(object):
euid = pwd.getpwuid(os.geteuid())[0] euid = pwd.getpwuid(os.geteuid())[0]
if self.transport == 'local' and self.remote_user != euid: if self.transport == 'local' and self.remote_user != euid:
raise Exception("User mismatch: expected %s, but is %s" % (self.remote_user, euid)) raise Exception("User mismatch: expected %s, but is %s" % (self.remote_user, euid))
if type(self.module_args) != str and type(self.module_args) != dict: if type(self.module_args) not in [str, unicode, dict]:
raise Exception("module_args must be a string or dict: %s" % self.module_args) raise Exception("module_args must be a string or dict: %s" % self.module_args)
self._tmp_paths = {} self._tmp_paths = {}