@@ -463,7 +463,7 @@ def test_archive_push_file_exists_overwrite(self):
463463 self .add_instance (backup_dir , 'node' , node )
464464 self .set_archiving (backup_dir , 'node' , node )
465465
466- wals_dir = os .path .join (backup_dir , 'wal' , 'node' )
466+ wals_dir = os .path .join (backup_dir , 'wal' , 'node' , '00000000' )
467467 if self .archive_compress :
468468 filename = '000000010000000000000001.gz'
469469 file = os .path .join (wals_dir , filename )
@@ -1469,7 +1469,7 @@ def test_archive_catalog(self):
14691469 self .assertTrue (timeline ['status' ], 'OK' )
14701470
14711471 # 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' )
14731473 wals = [
14741474 f for f in os .listdir (wals_dir ) if os .path .isfile (os .path .join (wals_dir , f ))
14751475 and not f .endswith ('.backup' ) and not f .endswith ('.history' ) and f .startswith ('00000003' )
@@ -1479,17 +1479,17 @@ def test_archive_catalog(self):
14791479 # check that t3 is ok
14801480 self .show_archive (backup_dir )
14811481
1482- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000017' )
1482+ file = os .path .join (wals_dir , '000000030000000000000017' )
14831483 if self .archive_compress :
14841484 file = file + '.gz'
14851485 os .remove (file )
14861486
1487- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000012' )
1487+ file = os .path .join (wals_dir , '000000030000000000000012' )
14881488 if self .archive_compress :
14891489 file = file + '.gz'
14901490 os .remove (file )
14911491
1492- file = os .path .join (backup_dir , 'wal' , 'replica' , '000000030000000000000013' )
1492+ file = os .path .join (wals_dir , '000000030000000000000013' )
14931493 if self .archive_compress :
14941494 file = file + '.gz'
14951495 os .remove (file )
0 commit comments