May 3, 2023 · Apr 10, 2023 · Apr 11, 2023 · Apr 11, 2023 · Apr 17, 2023 · Apr 28, 2023
diff --git a/testgres/node.py b/testgres/node.py
        process: wrapped psutill.Process object
        ptype: instance of ProcessType
    """

    def __init__(self, process, ptype=None):
        self.process = process
        self.ptype = ptype or ProcessType.from_process(process)
            return self

        _params = [
 get_bin_path("pg_ctl"),
 "-D", self.data_dir,
 "-l", self.pg_log_file,
 "-w" if wait else '-W',  # --wait or --no-wait
 "start"
 ] + params  # yapf: disable
            get_bin_path("pg_ctl"),
            "-D", self.data_dir,
            "-l", self.pg_log_file,
            "-w" if wait else '-W',  # --wait or --no-wait
            "start"
        ] + params  # yapf: disable

        try:
            execute_utility(_params, self.utils_log_file)
            """
        if self.is_started:
            sig = signal.SIGKILL if os.name != 'nt' else signal.SIGBREAK
            if someone== None:
            if someoneis None:
                os.kill(self.pid, sig)
            else:
                os.kill(self.auxiliary_pids[someone][0], sig)
        return sum

    def pgbench_table_checksums(self, dbname="postgres",
                                pgbench_tables =('pgbench_branches',
 'pgbench_tellers',
 'pgbench_accounts',
 'pgbench_history')
                                pgbench_tables=('pgbench_branches',
                                                'pgbench_tellers',
                                                'pgbench_accounts',
                                                'pgbench_history')
                                ):
        return {(table, self.table_checksum(table, dbname))
                for table in pgbench_tables}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -115,6 +115,7 @@ class ProcessProxy(object):
		process: wrapped psutill.Process object
		ptype: instance of ProcessType
		"""

		def __init__(self, process, ptype=None):
		self.process = process
		self.ptype = ptype or ProcessType.from_process(process)
Expand DownExpand Up		@@ -697,12 +698,12 @@ def start(self, params=[], wait=True):
		return self

		_params = [
		get_bin_path("pg_ctl"),
		"-D", self.data_dir,
		"-l", self.pg_log_file,
		"-w" if wait else '-W', # --wait or --no-wait
		"start"
		] + params # yapf: disable
		get_bin_path("pg_ctl"),
		"-D", self.data_dir,
		"-l", self.pg_log_file,
		"-w" if wait else '-W', # --wait or --no-wait
		"start"
		] + params # yapf: disable

		try:
		execute_utility(_params, self.utils_log_file)
Expand DownExpand Up		@@ -752,7 +753,7 @@ def kill(self, someone=None):
		"""
		if self.is_started:
		sig = signal.SIGKILL if os.name != 'nt' else signal.SIGBREAK
		if someone== None:
		if someoneis None:
		os.kill(self.pid, sig)
		else:
		os.kill(self.auxiliary_pids[someone][0], sig)
Expand DownExpand Up		@@ -1496,10 +1497,10 @@ def querier():
		return sum

		def pgbench_table_checksums(self, dbname="postgres",
		pgbench_tables =('pgbench_branches',
		'pgbench_tellers',
		'pgbench_accounts',
		'pgbench_history')
		pgbench_tables=('pgbench_branches',
		'pgbench_tellers',
		'pgbench_accounts',
		'pgbench_history')
		):
		return {(table, self.table_checksum(table, dbname))
		for table in pgbench_tables}
Expand Down