if self.host is None:
return self.local_execute(command)
- cmd = ["ssh", self.user + "@" + self.host, ' '.join(command)]
+ if self.user:
+ cmd = ["ssh", self.user + "@" + self.host, ' '.join(command)]
+ else:
+ cmd = ["ssh", self.host, ' '.join(command)]
_cmd = self.name + " execute: " + ' '.join(cmd)
logger.debug(_cmd)
err = tempfile.TemporaryFile()
if self.host is None:
cmd = _command
else:
- cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
+ if self.user:
+ cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
+ else:
+ cmd = ["ssh", self.host, ' '.join(_command)]
_cmd = self.name + " thread_run: " + ' '.join(cmd)
logger.debug(_cmd)
t = threading.Thread(target=execute_thread, name=filename, args=(cmd, res))
_command = [filename] + command
if self.host:
- cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
+ if self.user:
+ cmd = ["ssh", self.user + "@" + self.host, ' '.join(_command)]
+ else:
+ cmd = ["ssh", self.host, ' '.join(_command)]
else:
cmd = _command
def get_logs(self, local_log_dir=None):
for log in self.logs:
if local_log_dir:
- self.local_execute(["scp", self.user + "@[" + self.host + "]:" + log, local_log_dir])
+ if self.user:
+ self.local_execute(["scp", self.user + "@[" + self.host + "]:" + log, local_log_dir])
+ else:
+ self.local_execute(["scp", "[" + self.host + "]:" + log, local_log_dir])
self.execute(["rm", log])
del self.logs[:]
def send_file(self, src, dst):
if self.host is None:
return
- self.local_execute(["scp", src,
- self.user + "@[" + self.host + "]:" + dst])
+ if self.user:
+ self.local_execute(["scp", src,
+ self.user + "@[" + self.host + "]:" + dst])
+ else:
+ self.local_execute(["scp", src, "[" + self.host + "]:" + dst])