@@ -463,7 +463,7 @@ def test_archive_push_file_exists_overwrite(self):
463
463
self .add_instance (backup_dir , 'node' , node )
464
464
self .set_archiving (backup_dir , 'node' , node )
465
465
466
- wals_dir = os .path .join (backup_dir , 'wal' , 'node' )
466
+ wals_dir = os .path .join (backup_dir , 'wal' , 'node' , '00000000' )
467
467
if self .archive_compress :
468
468
filename = '000000010000000000000001.gz'
469
469
file = os .path .join (wals_dir , filename )
@@ -1469,7 +1469,7 @@ def test_archive_catalog(self):
1469
1469
self .assertTrue (timeline ['status' ], 'OK' )
1470
1470
1471
1471
# create holes in t3
1472
- wals_dir = os .path .join (backup_dir , 'wal' , 'replica' )
1472
+ wals_dir = os .path .join (backup_dir , 'wal' , 'replica' , '00000000' )
1473
1473
wals = [
1474
1474
f for f in os .listdir (wals_dir ) if os .path .isfile (os .path .join (wals_dir , f ))
1475
1475
and not f .endswith ('.backup' ) and not f .endswith ('.history' ) and f .startswith ('00000003' )
@@ -1479,17 +1479,17 @@ def test_archive_catalog(self):
1479
1479
# check that t3 is ok
1480
1480
self .show_archive (backup_dir )
1481
1481
1482
- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000017' )
1482
+ file = os .path .join (wals_dir , '000000030000000000000017' )
1483
1483
if self .archive_compress :
1484
1484
file = file + '.gz'
1485
1485
os .remove (file )
1486
1486
1487
- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000012' )
1487
+ file = os .path .join (wals_dir , '000000030000000000000012' )
1488
1488
if self .archive_compress :
1489
1489
file = file + '.gz'
1490
1490
os .remove (file )
1491
1491
1492
- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000013' )
1492
+ file = os .path .join (wals_dir , '000000030000000000000013' )
1493
1493
if self .archive_compress :
1494
1494
file = file + '.gz'
1495
1495
os .remove (file )
0 commit comments