self._handle_failure(command, status)
if self.config.get('reconnect', True) is True:
- remotes = self.cluster.remotes.keys()
+ remotes = list(self.cluster.remotes)
log.debug("Reconnecting to %s", remotes)
for remote in remotes:
remote.reconnect()
"""
fqdns = [r.hostname for r in self.cluster.remotes.keys()]
# Assume all remotes use the same username
- user = self.cluster.remotes.keys()[0].user
+ user = list(self.cluster.remotes)[0].user
extra_vars = dict(ansible_ssh_user=user)
extra_vars.update(self.config.get('vars', dict()))
args = [
self.stop_patchers()
def stop_patchers(self):
- for name in self.mocks.keys():
+ for name in list(self.mocks):
self.stop_patcher(name)
def stop_patcher(self, name):
assert args.count('--extra-vars') == 1
vars_str = args[args.index('--extra-vars') + 1].strip("'")
extra_vars = json.loads(vars_str)
- assert extra_vars.keys() == ['ansible_ssh_user']
+ assert list(extra_vars) == ['ansible_ssh_user']
def test_build_args_vars(self):
extra_vars = dict(