diff --git a/src/python/jw/pkg/lib/ec/ssh/Exec.py b/src/python/jw/pkg/lib/ec/ssh/Exec.py index e27a2c42..ba6a02e6 100644 --- a/src/python/jw/pkg/lib/ec/ssh/Exec.py +++ b/src/python/jw/pkg/lib/ec/ssh/Exec.py @@ -60,4 +60,8 @@ class Exec(Base): if env: for key, val in env.items(): opts.extend(['-o', f'SetEnv {key}="{val}"']) + if self.username: + opts.extend(['-l', self.username]) + if self.port is not None: + pots.extend(['-p', str(self.port)]) return await run_cmd(['ssh', *opts, self.hostname, join_cmd(cmd)], cmd_input=cmd_input, throw=False)