Signed-off-by: Zack Cerza <zack@redhat.com>
self._host_key = host_key
self.keep_alive = keep_alive
self.console = console
- self.ssh = ssh or self.connect()
+ self.ssh = ssh
def connect(self):
self.ssh = connection.connect(user_at_host=self.name,
key = None
except (AttributeError, KeyError):
pass
- remotes.append(
- remote.Remote(name=t, host_key=key, keep_alive=True, console=None))
+ rem = remote.Remote(name=t, host_key=key, keep_alive=True)
+ rem.connect()
+ remotes.append(rem)
ctx.cluster = cluster.Cluster()
if 'roles' in ctx.config:
for rem, roles in zip(remotes, ctx.config['roles']):