@@ -1919,7 +1919,8 @@ def test_archive_pg_receivexlog_partial_handling(self):
19191919node = self .make_simple_node (
19201920base_dir = os .path .join (module_name ,fname ,'node' ),
19211921set_replication = True ,
1922- initdb_params = ['--data-checksums' ])
1922+ initdb_params = ['--data-checksums' ],
1923+ pg_options = {'archive_timeout' :'10s' })
19231924
19241925self .init_pb (backup_dir )
19251926self .add_instance (backup_dir ,'node' ,node )
@@ -1942,9 +1943,6 @@ def test_archive_pg_receivexlog_partial_handling(self):
19421943
19431944replica .slow_start (replica = True )
19441945
1945- # FULL
1946- self .backup_node (backup_dir ,'replica' ,replica ,options = ['--stream' ])
1947-
19481946if self .get_version (replica )< 100000 :
19491947pg_receivexlog_path = self .get_bin_path ('pg_receivexlog' )
19501948else :
@@ -1965,9 +1963,8 @@ def test_archive_pg_receivexlog_partial_handling(self):
19651963'Failed to start pg_receivexlog: {0}' .format (
19661964pg_receivexlog .communicate ()[1 ]))
19671965
1968- replica .safe_psql (
1969- 'postgres' ,
1970- 'CHECKPOINT' )
1966+ # FULL
1967+ self .backup_node (backup_dir ,'replica' ,replica ,options = ['--stream' ])
19711968
19721969node .safe_psql (
19731970"postgres" ,
@@ -1976,7 +1973,8 @@ def test_archive_pg_receivexlog_partial_handling(self):
19761973"from generate_series(0,1000000) i" )
19771974
19781975# PAGE
1979- self .backup_node (backup_dir ,'replica' ,replica ,backup_type = 'page' )
1976+ self .backup_node (
1977+ backup_dir ,'replica' ,replica ,backup_type = 'delta' ,options = ['--stream' ])
19801978
19811979node .safe_psql (
19821980"postgres" ,
@@ -2013,7 +2011,8 @@ def test_archive_pg_receivexlog_partial_handling(self):
20132011
20142012# Clean after yourself
20152013pg_receivexlog .kill ()
2016- self .del_test_dir (module_name ,fname )
2014+ self .del_test_dir (
2015+ module_name ,fname , [node ,replica ,node_restored ])
20172016
20182017@unittest .skip ("skip" )
20192018def test_multi_timeline_recovery_prefetching (self ):