Skip to content

Commit bc48e31

Browse files
PostgresNode is updated (self._os_ops is used)
1 parent fdf8fcb commit bc48e31

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

src/node.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -985,7 +985,7 @@ def slow_start(self, replica=False, dbname='template1', username=None, max_attem
985985
self.poll_query_until(
986986
query=query,
987987
dbname=dbname,
988-
username=username or self.os_ops.username,
988+
username=username or self._os_ops.username,
989989
suppress=suppressed_exceptions,
990990
max_attempts=max_attempts,
991991
)
@@ -1450,7 +1450,7 @@ def _psql(
14501450
self._get_bin_path("psql"),
14511451
"-p", str(port),
14521452
"-h", host,
1453-
"-U", username or self.os_ops.username,
1453+
"-U", username or self._os_ops.username,
14541454
"-d", dbname or default_dbname(),
14551455
"-X", # no .psqlrc
14561456
"-A", # unaligned output
@@ -1565,7 +1565,7 @@ def tmpfile():
15651565
"-p", str(self.port),
15661566
"-h", self.host,
15671567
"-f", filename,
1568-
"-U", username or self.os_ops.username,
1568+
"-U", username or self._os_ops.username,
15691569
"-d", dbname or default_dbname(),
15701570
"-F", format.value
15711571
] # yapf: disable
@@ -1590,7 +1590,7 @@ def restore(self, filename, dbname=None, username=None):
15901590

15911591
# Set default arguments
15921592
dbname = dbname or default_dbname()
1593-
username = username or self.os_ops.username
1593+
username = username or self._os_ops.username
15941594

15951595
_params = [
15961596
self._get_bin_path("pg_restore"),
@@ -1868,7 +1868,7 @@ def pgbench(self,
18681868
self._get_bin_path("pgbench"),
18691869
"-p", str(self.port),
18701870
"-h", self.host,
1871-
"-U", username or self.os_ops.username
1871+
"-U", username or self._os_ops.username
18721872
] + options # yapf: disable
18731873

18741874
# should be the last one
@@ -1941,7 +1941,7 @@ def pgbench_run(self, dbname=None, username=None, options=[], **kwargs):
19411941
self._get_bin_path("pgbench"),
19421942
"-p", str(self.port),
19431943
"-h", self.host,
1944-
"-U", username or self.os_ops.username
1944+
"-U", username or self._os_ops.username
19451945
] + options # yapf: disable
19461946

19471947
for key, value in iteritems(kwargs):

0 commit comments

Comments
 (0)