@@ -463,7 +463,7 @@ def test_archive_push_file_exists_overwrite(self):
463463self .add_instance (backup_dir ,'node' ,node )
464464self .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' )
467467if self .archive_compress :
468468filename = '000000010000000000000001.gz'
469469file = os .path .join (wals_dir ,filename )
@@ -1469,7 +1469,7 @@ def test_archive_catalog(self):
14691469self .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' )
14731473wals = [
14741474f for f in os .listdir (wals_dir )if os .path .isfile (os .path .join (wals_dir ,f ))
14751475and 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
14801480self .show_archive (backup_dir )
14811481
1482- file = os .path .join (backup_dir , 'wal' , 'replica' ,'000000030000000000000017' )
1482+ file = os .path .join (wals_dir ,'000000030000000000000017' )
14831483if self .archive_compress :
14841484file = file + '.gz'
14851485os .remove (file )
14861486
1487- file = os .path .join (backup_dir , 'wal' , 'replica' ,'000000030000000000000012' )
1487+ file = os .path .join (wals_dir ,'000000030000000000000012' )
14881488if self .archive_compress :
14891489file = file + '.gz'
14901490os .remove (file )
14911491
1492- file = os .path .join (backup_dir , 'wal' , 'replica' ,'000000030000000000000013' )
1492+ file = os .path .join (wals_dir ,'000000030000000000000013' )
14931493if self .archive_compress :
14941494file = file + '.gz'
14951495os .remove (file )