@@ -1873,10 +1873,6 @@ def test_wal_file_path_2(self):
1873
1873
# FULL
1874
1874
self .backup_node (backup_dir , 'node' , node , options = ['--stream' ])
1875
1875
1876
- # self.run_pb(["archive-push", "-B", backup_dir,
1877
- # "--instance=node", "-D", node.data_dir,
1878
- # "--wal-file-name=%%f"])#"--wal-file-path=%%p",
1879
-
1880
1876
log_file = os .path .join (node .logs_dir , 'postgresql.log' )
1881
1877
with open (log_file , 'r' ) as f :
1882
1878
log_content = f .read ()
@@ -1903,27 +1899,41 @@ def test_wal_file_path_3(self):
1903
1899
self .add_instance (backup_dir , 'node' , node )
1904
1900
self .set_archiving (backup_dir , 'node' , node , compress = True )
1905
1901
1906
- wal_dir = os .path .join (backup_dir , 'wal' , 'node' )
1907
- self .set_auto_conf (node , {'archive_command' : "cp -r \" {0}\" \" {1}\" " .format (backup_dir , wal_dir )})
1902
+ wal_dir = os .path .join (self .tmp_path , module_name , fname , 'wal_dir' )
1903
+ os .mkdir (wal_dir )
1904
+ self .set_config (
1905
+ backup_dir , 'node' ,
1906
+ options = ['--log-level-file=VERBOSE' ])
1907
+ self .set_auto_conf (node , {'archive_command' : "cp -v %p {0}/%f" .format (wal_dir )})
1908
1908
1909
1909
node .slow_start ()
1910
1910
node .safe_psql (
1911
1911
"postgres" ,
1912
1912
"create table t_heap as select i"
1913
- " as id from generate_series(0,100 ) i" )
1913
+ " as id from generate_series(0,1000 ) i" )
1914
1914
1915
1915
# FULL
1916
1916
self .backup_node (backup_dir , 'node' , node , options = ['--stream' ])
1917
1917
1918
+ node .safe_psql (
1919
+ "postgres" ,
1920
+ "insert into t_heap select i"
1921
+ " as id from generate_series(0,1000) i" )
1922
+ self .backup_node (backup_dir , 'node' , node ,
1923
+ options = ['--stream' ])
1924
+
1925
+ filename = '000000010000000000000001'
1926
+
1918
1927
self .run_pb (["archive-push" , "-B" , backup_dir ,
1919
1928
"--instance=node" , "-D" , node .data_dir ,
1920
- "--wal-file-path" , wal_dir , "--wal-file-name=%f" ])
1929
+ "--wal-file-path" , wal_dir , "--wal-file-name" , filename ])
1921
1930
1922
- log_file = os .path .join (node .logs_dir , 'postgresql.log' )
1931
+ log_file = os .path .join (
1932
+ backup_dir , 'log' , 'pg_probackup.log' )
1923
1933
with open (log_file , 'r' ) as f :
1924
1934
log_content = f .read ()
1925
1935
1926
- self .assertIn ('wal_file_path is setted by user ' , log_content )
1936
+ self .assertIn ('pg_probackup archive-push completed successfully ' , log_content )
1927
1937
1928
1938
self .del_test_dir (module_name , fname )
1929
1939
0 commit comments