Nov 1, 2024 · Nov 1, 2024 · Nov 18, 2024 · Nov 18, 2024 · Nov 18, 2024 · Nov 18, 2024
diff --git a/testgres/node.py b/testgres/node.py

        # should be the last one
        psql_params.append(dbname)
        if not self.os_ops.conn_params.remote:
            # start psql process
            process = subprocess.Popen(psql_params,
                                       stdin=subprocess.PIPE,
                                       stdout=subprocess.PIPE,
                                       stderr=subprocess.PIPE)

        return self.os_ops.exec_command(
            psql_params,
diff --git a/testgres/operations/local_ops.py b/testgres/operations/local_ops.py

 from ..exceptions import ExecUtilException
 from .os_ops import ConnectionParams, OsOperations, get_default_encoding
 from .raise_error import RaiseError
 from .helpers import Helpers

 try:
    from shutil import which as find_executable
diff --git a/tests/test_remote.py b/tests/test_remote.py
                error = e.message
                break
            raise Exception("We wait an exception!")
        assert error == 'Utility exited with non-zero code. Error: bash: line 1: nonexistent_command: command not found\n'
        assert error == 'Utility exited with non-zero code. Error:`bash: line 1: nonexistent_command: command not found`'

    def test_exec_command_failure__expect_error(self):
        """
            self.operations.makedirs(path)

        # Test rmdirs
        try:
            exit_status, result, error = self.operations.rmdirs(path, verbose=True)
        except ExecUtilException as e:
            error = e.message
        assert error == "Utility exited with non-zero code. Error: rm: cannot remove '/root/test_dir': Permission denied\n"
        while True:
            try:
                self.operations.rmdirs(path, verbose=True)
            except ExecUtilException as e:
                error = e.message
                break
            raise Exception("We wait an exception!")
        assert error == "Utility exited with non-zero code. Error: `rm: cannot remove '/root/test_dir': Permission denied`"

    def test_listdir(self):
        """
Original file line number	Diff line number	Diff line change
Expand Up		@@ -1067,12 +1067,6 @@ def _psql(

		# should be the last one
		psql_params.append(dbname)
		if not self.os_ops.conn_params.remote:
		# start psql process
		process = subprocess.Popen(psql_params,
		stdin=subprocess.PIPE,
		stdout=subprocess.PIPE,
		stderr=subprocess.PIPE)

		return self.os_ops.exec_command(
		psql_params,
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -10,6 +10,8 @@

		from ..exceptions import ExecUtilException
		from .os_ops import ConnectionParams, OsOperations, get_default_encoding
		from .raise_error import RaiseError
		from .helpers import Helpers

		try:
		from shutil import which as find_executable
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -37,7 +37,7 @@ def test_exec_command_failure(self):
		error = e.message
		break
		raise Exception("We wait an exception!")
		assert error == 'Utility exited with non-zero code. Error: bash: line 1: nonexistent_command: command not found\n'
		assert error == 'Utility exited with non-zero code. Error:`bash: line 1: nonexistent_command: command not found`'

		def test_exec_command_failure__expect_error(self):
		"""
Expand DownExpand Up		@@ -98,11 +98,14 @@ def test_makedirs_and_rmdirs_failure(self):
		self.operations.makedirs(path)

		# Test rmdirs
		try:
		exit_status, result, error = self.operations.rmdirs(path, verbose=True)
		except ExecUtilException as e:
		error = e.message
		assert error == "Utility exited with non-zero code. Error: rm: cannot remove '/root/test_dir': Permission denied\n"
		while True:
		try:
		self.operations.rmdirs(path, verbose=True)
		except ExecUtilException as e:
		error = e.message
		break
		raise Exception("We wait an exception!")
		assert error == "Utility exited with non-zero code. Error: `rm: cannot remove '/root/test_dir': Permission denied`"

		def test_listdir(self):
		"""
Expand Down