Skip to content

Commit 8a37325

Browse files
committed
enable streaming for pg_basebackup
1 parent 023c3fb commit 8a37325

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

testgres/tests/test_simple.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -155,9 +155,8 @@ def test_control_data(self):
155155

156156
def test_backup_simple(self):
157157
with get_new_node('master') as master:
158+
master.init(allow_streaming=True).start()
158159

159-
master.init(allow_streaming=True)
160-
master.start()
161160
master.psql('postgres',
162161
'create table test as select generate_series(1, 4) i')
163162

@@ -170,7 +169,7 @@ def test_backup_simple(self):
170169

171170
def test_backup_multiple(self):
172171
with get_new_node('node') as node:
173-
node.init().start()
172+
node.init(allow_streaming=True).start()
174173

175174
with node.backup('fetch') as backup1, \
176175
node.backup('fetch') as backup2:
@@ -185,7 +184,7 @@ def test_backup_multiple(self):
185184

186185
def test_backup_exhaust(self):
187186
with get_new_node('node') as node:
188-
node.init().start()
187+
node.init(allow_streaming=True).start()
189188

190189
with node.backup('fetch') as backup:
191190
with backup.spawn_primary('node1') as node1:
@@ -242,6 +241,7 @@ def test_backup_and_replication(self):
242241
self.assertEqual(res[1][0], 3)
243242
self.assertEqual(res[1][1], 4)
244243

244+
# check manual cleanup
245245
replica.cleanup()
246246
replica.free_port()
247247

0 commit comments

Comments
 (0)