diff --git a/src/backup.py b/src/backup.py index 6b1b1bc6..d91db5a0 100644 --- a/src/backup.py +++ b/src/backup.py @@ -152,12 +152,7 @@ def spawn_primary(self, name=None, destroy=True): # Build a new PostgresNode assert self.original_node is not None - if (hasattr(self.original_node, "clone_with_new_name_and_base_dir")): - node = self.original_node.clone_with_new_name_and_base_dir(name=name, base_dir=base_dir) - else: - # For backward compatibility - NodeClass = self.original_node.__class__ - node = NodeClass(name=name, base_dir=base_dir, conn_params=self.original_node.os_ops.conn_params) + node = self.original_node.clone_with_new_name_and_base_dir(name=name, base_dir=base_dir) assert node is not None assert type(node) is self.original_node.__class__ diff --git a/src/node.py b/src/node.py index cdf851c3..6fa4fed5 100644 --- a/src/node.py +++ b/src/node.py @@ -101,7 +101,6 @@ from .backup import NodeBackup -from testgres.operations.os_ops import ConnectionParams from testgres.operations.os_ops import OsOperations from testgres.operations.local_ops import LocalOperations @@ -174,7 +173,6 @@ def __init__(self, name=None, base_dir=None, port: typing.Optional[int] = None, - conn_params: typing.Optional[ConnectionParams] = None, bin_dir=None, prefix=None, os_ops: typing.Optional[OsOperations] = None, @@ -194,11 +192,6 @@ def __init__(self, assert os_ops is None or isinstance(os_ops, OsOperations) assert port_manager is None or isinstance(port_manager, PortManager) - if conn_params is not None: - assert type(conn_params) is ConnectionParams - - raise InvalidOperationException("conn_params is deprecated, please use os_ops parameter instead.") - # private if os_ops is None: self._os_ops = __class__._get_os_ops()