diff --git a/docs/source/changelog.rst b/docs/source/changelog.rst index 81f23278..509c0de4 100644 --- a/docs/source/changelog.rst +++ b/docs/source/changelog.rst @@ -1,4 +1,4 @@ -.. Created by changelog.py at 2023-10-10, command +.. Created by changelog.py at 2023-11-09, command '/Users/giffler/.cache/pre-commit/repor6pnmwlm/py_env-python3.10/bin/changelog docs/source/changes compile --categories Added Changed Fixed Security Deprecated --output=docs/source/changelog.rst' based on the format of 'https://keepachangelog.com/' diff --git a/tardis/utilities/executors/sshexecutor.py b/tardis/utilities/executors/sshexecutor.py index 40c6785c..4331e549 100644 --- a/tardis/utilities/executors/sshexecutor.py +++ b/tardis/utilities/executors/sshexecutor.py @@ -90,7 +90,7 @@ async def run_command(self, command, stdin_input=None): async with self.bounded_connection as ssh_connection: try: response = await ssh_connection.run( - command, check=True, input=stdin_input and stdin_input.encode() + command, check=True, input=stdin_input and stdin_input ) except asyncssh.ProcessError as pe: raise CommandExecutionFailure( diff --git a/tests/utilities_t/executors_t/test_sshexecutor.py b/tests/utilities_t/executors_t/test_sshexecutor.py index ae83f7b5..c0c48674 100644 --- a/tests/utilities_t/executors_t/test_sshexecutor.py +++ b/tests/utilities_t/executors_t/test_sshexecutor.py @@ -43,7 +43,7 @@ async def run(self, command, input=None, **kwargs): elif command != "Test": raise ValueError(f"Unsupported mock command: {command}") return AttributeDict( - stdout=input and input.decode(), stderr="TestError", exit_status=0 + stdout=input and input, stderr="TestError", exit_status=0 ) async def create_process(self):