@@ -70,9 +70,9 @@ def test_basic_incr_restore(self):
70
70
71
71
node .stop ()
72
72
73
- print ( self .restore_node (
73
+ self .restore_node (
74
74
backup_dir , 'node' , node ,
75
- options = ["-j" , "4" , "--incremental-mode=checksum" ]))
75
+ options = ["-j" , "4" , "--incremental-mode=checksum" ])
76
76
77
77
pgdata_restored = self .pgdata_content (node .data_dir )
78
78
self .compare_pgdata (pgdata , pgdata_restored )
@@ -119,9 +119,9 @@ def test_basic_incr_restore_into_missing_directory(self):
119
119
120
120
node .cleanup ()
121
121
122
- print ( self .restore_node (
122
+ self .restore_node (
123
123
backup_dir , 'node' , node ,
124
- options = ["-j" , "4" , "--incremental-mode=checksum" ]))
124
+ options = ["-j" , "4" , "--incremental-mode=checksum" ])
125
125
126
126
pgdata_restored = self .pgdata_content (node .data_dir )
127
127
self .compare_pgdata (pgdata , pgdata_restored )
@@ -453,7 +453,6 @@ def test_incr_restore_with_tablespace_4(self):
453
453
"Output: {0} \n CMD: {1}" .format (
454
454
repr (self .output ), self .cmd ))
455
455
except ProbackupException as e :
456
- print (e .message )
457
456
self .assertIn (
458
457
'WARNING: Backup catalog was initialized for system id' ,
459
458
e .message ,
@@ -649,8 +648,6 @@ def test_incr_restore_with_tablespace_7(self):
649
648
options = [
650
649
"-j" , "4" , "--incremental-mode=checksum" ])
651
650
652
- print (out )
653
-
654
651
pgdata_restored = self .pgdata_content (node .data_dir )
655
652
self .compare_pgdata (pgdata , pgdata_restored )
656
653
@@ -800,9 +797,9 @@ def test_incr_checksum_restore(self):
800
797
801
798
pgdata = self .pgdata_content (node_1 .data_dir )
802
799
803
- print ( self .restore_node (
800
+ self .restore_node (
804
801
backup_dir , 'node' , node ,
805
- options = ["-j" , "4" , "--incremental-mode=checksum" ]))
802
+ options = ["-j" , "4" , "--incremental-mode=checksum" ])
806
803
807
804
pgdata_restored = self .pgdata_content (node .data_dir )
808
805
@@ -890,8 +887,8 @@ def test_incr_lsn_restore(self):
890
887
891
888
pgdata = self .pgdata_content (node_1 .data_dir )
892
889
893
- print ( self .restore_node (
894
- backup_dir , 'node' , node , options = ["-j" , "4" , "--incremental-mode=lsn" ]))
890
+ self .restore_node (
891
+ backup_dir , 'node' , node , options = ["-j" , "4" , "--incremental-mode=lsn" ])
895
892
896
893
pgdata_restored = self .pgdata_content (node .data_dir )
897
894
@@ -1079,9 +1076,9 @@ def test_incr_checksum_corruption_detection(self):
1079
1076
f .flush ()
1080
1077
f .close
1081
1078
1082
- print ( self .restore_node (
1079
+ self .restore_node (
1083
1080
backup_dir , 'node' , node , data_dir = node .data_dir ,
1084
- options = ["-j" , "4" , "--incremental-mode=checksum" ]))
1081
+ options = ["-j" , "4" , "--incremental-mode=checksum" ])
1085
1082
1086
1083
pgdata_restored = self .pgdata_content (node .data_dir )
1087
1084
@@ -1209,9 +1206,9 @@ def test_incr_restore_multiple_external(self):
1209
1206
1210
1207
node .stop ()
1211
1208
1212
- print ( self .restore_node (
1209
+ self .restore_node (
1213
1210
backup_dir , 'node' , node ,
1214
- options = ["-j" , "4" , '--incremental-mode=checksum' , '--log-level-console=VERBOSE' ]) )
1211
+ options = ["-j" , "4" , '--incremental-mode=checksum' ] )
1215
1212
1216
1213
pgdata_restored = self .pgdata_content (
1217
1214
node .base_dir , exclude_dirs = ['logs' ])
@@ -1281,9 +1278,9 @@ def test_incr_lsn_restore_multiple_external(self):
1281
1278
1282
1279
node .stop ()
1283
1280
1284
- print ( self .restore_node (
1281
+ self .restore_node (
1285
1282
backup_dir , 'node' , node ,
1286
- options = ["-j" , "4" , '--incremental-mode=lsn' ]))
1283
+ options = ["-j" , "4" , '--incremental-mode=lsn' ])
1287
1284
1288
1285
pgdata_restored = self .pgdata_content (
1289
1286
node .base_dir , exclude_dirs = ['logs' ])
@@ -1341,11 +1338,13 @@ def test_incr_lsn_restore_backward(self):
1341
1338
1342
1339
node .stop ()
1343
1340
1344
- print ( self .restore_node (
1341
+ self .restore_node (
1345
1342
backup_dir , 'node' , node , backup_id = full_id ,
1346
1343
options = [
1347
- "-j" , "4" , '--incremental-mode=lsn' , '--log-level-file=VERBOSE' ,
1348
- '--recovery-target=immediate' , '--recovery-target-action=pause' ]))
1344
+ "-j" , "4" ,
1345
+ '--incremental-mode=lsn' ,
1346
+ '--recovery-target=immediate' ,
1347
+ '--recovery-target-action=pause' ])
1349
1348
1350
1349
pgdata_restored = self .pgdata_content (node .data_dir )
1351
1350
self .compare_pgdata (full_pgdata , pgdata_restored )
@@ -1384,11 +1383,13 @@ def test_incr_lsn_restore_backward(self):
1384
1383
node .slow_start (replica = True )
1385
1384
node .stop ()
1386
1385
1387
- print ( self .restore_node (
1386
+ self .restore_node (
1388
1387
backup_dir , 'node' , node , backup_id = delta_id ,
1389
1388
options = [
1390
- "-j" , "4" , '--incremental-mode=lsn' ,
1391
- '--recovery-target=immediate' , '--recovery-target-action=pause' ]))
1389
+ "-j" , "4" ,
1390
+ '--incremental-mode=lsn' ,
1391
+ '--recovery-target=immediate' ,
1392
+ '--recovery-target-action=pause' ])
1392
1393
1393
1394
pgdata_restored = self .pgdata_content (node .data_dir )
1394
1395
self .compare_pgdata (delta_pgdata , pgdata_restored )
@@ -1447,35 +1448,41 @@ def test_incr_checksum_restore_backward(self):
1447
1448
1448
1449
node .stop ()
1449
1450
1450
- print ( self .restore_node (
1451
+ self .restore_node (
1451
1452
backup_dir , 'node' , node , backup_id = full_id ,
1452
1453
options = [
1453
- "-j" , "4" , '--incremental-mode=checksum' ,
1454
- '--recovery-target=immediate' , '--recovery-target-action=pause' ]))
1454
+ "-j" , "4" ,
1455
+ '--incremental-mode=checksum' ,
1456
+ '--recovery-target=immediate' ,
1457
+ '--recovery-target-action=pause' ])
1455
1458
1456
1459
pgdata_restored = self .pgdata_content (node .data_dir )
1457
1460
self .compare_pgdata (full_pgdata , pgdata_restored )
1458
1461
1459
1462
node .slow_start (replica = True )
1460
1463
node .stop ()
1461
1464
1462
- print ( self .restore_node (
1465
+ self .restore_node (
1463
1466
backup_dir , 'node' , node , backup_id = page_id ,
1464
1467
options = [
1465
- "-j" , "4" , '--incremental-mode=checksum' ,
1466
- '--recovery-target=immediate' , '--recovery-target-action=pause' ]))
1468
+ "-j" , "4" ,
1469
+ '--incremental-mode=checksum' ,
1470
+ '--recovery-target=immediate' ,
1471
+ '--recovery-target-action=pause' ])
1467
1472
1468
1473
pgdata_restored = self .pgdata_content (node .data_dir )
1469
1474
self .compare_pgdata (page_pgdata , pgdata_restored )
1470
1475
1471
1476
node .slow_start (replica = True )
1472
1477
node .stop ()
1473
1478
1474
- print ( self .restore_node (
1479
+ self .restore_node (
1475
1480
backup_dir , 'node' , node , backup_id = delta_id ,
1476
1481
options = [
1477
- "-j" , "4" , '--incremental-mode=checksum' ,
1478
- '--recovery-target=immediate' , '--recovery-target-action=pause' ]))
1482
+ "-j" , "4" ,
1483
+ '--incremental-mode=checksum' ,
1484
+ '--recovery-target=immediate' ,
1485
+ '--recovery-target-action=pause' ])
1479
1486
1480
1487
pgdata_restored = self .pgdata_content (node .data_dir )
1481
1488
self .compare_pgdata (delta_pgdata , pgdata_restored )
@@ -1542,9 +1549,9 @@ def test_make_replica_via_incr_checksum_restore(self):
1542
1549
data_dir = new_master .data_dir , backup_type = 'page' )
1543
1550
1544
1551
# restore old master as replica
1545
- print ( self .restore_node (
1552
+ self .restore_node (
1546
1553
backup_dir , 'node' , old_master , data_dir = old_master .data_dir ,
1547
- options = ['-R' , '--incremental-mode=checksum' ]))
1554
+ options = ['-R' , '--incremental-mode=checksum' ])
1548
1555
1549
1556
self .set_replica (new_master , old_master , synchronous = True )
1550
1557
@@ -1615,9 +1622,9 @@ def test_make_replica_via_incr_lsn_restore(self):
1615
1622
data_dir = new_master .data_dir , backup_type = 'page' )
1616
1623
1617
1624
# restore old master as replica
1618
- print ( self .restore_node (
1625
+ self .restore_node (
1619
1626
backup_dir , 'node' , old_master , data_dir = old_master .data_dir ,
1620
- options = ['-R' , '--incremental-mode=lsn' ]))
1627
+ options = ['-R' , '--incremental-mode=lsn' ])
1621
1628
1622
1629
self .set_replica (new_master , old_master , synchronous = True )
1623
1630
@@ -1762,9 +1769,9 @@ def test_incr_lsn_long_xact_1(self):
1762
1769
node .stop ()
1763
1770
1764
1771
try :
1765
- print ( self .restore_node (
1772
+ self .restore_node (
1766
1773
backup_dir , 'node' , node , backup_id = full_id ,
1767
- options = ["-j" , "4" , '--incremental-mode=lsn' ]))
1774
+ options = ["-j" , "4" , '--incremental-mode=lsn' ])
1768
1775
# we should die here because exception is what we expect to happen
1769
1776
self .assertEqual (
1770
1777
1 , 0 ,
@@ -1920,9 +1927,9 @@ def test_incr_restore_zero_size_file_checksum(self):
1920
1927
1921
1928
node .stop ()
1922
1929
1923
- print ( self .restore_node (
1930
+ self .restore_node (
1924
1931
backup_dir , 'node' , node , backup_id = id1 ,
1925
- options = ["-j" , "4" , '-I' , 'checksum' ]))
1932
+ options = ["-j" , "4" , '-I' , 'checksum' ])
1926
1933
1927
1934
pgdata_restored = self .pgdata_content (node .data_dir )
1928
1935
self .compare_pgdata (pgdata1 , pgdata_restored )
@@ -1994,9 +2001,9 @@ def test_incr_restore_zero_size_file_lsn(self):
1994
2001
1995
2002
node .stop ()
1996
2003
1997
- print ( self .restore_node (
2004
+ self .restore_node (
1998
2005
backup_dir , 'node' , node , backup_id = id1 ,
1999
- options = ["-j" , "4" , '-I' , 'checksum' ]))
2006
+ options = ["-j" , "4" , '-I' , 'checksum' ])
2000
2007
2001
2008
pgdata_restored = self .pgdata_content (node .data_dir )
2002
2009
self .compare_pgdata (pgdata1 , pgdata_restored )
@@ -2088,12 +2095,12 @@ def test_incremental_partial_restore_exclude_checksum(self):
2088
2095
pgdata1 = self .pgdata_content (node1 .data_dir )
2089
2096
2090
2097
# partial incremental restore backup into node2
2091
- print ( self .restore_node (
2098
+ self .restore_node (
2092
2099
backup_dir , 'node' ,
2093
2100
node2 , options = [
2094
2101
"--db-exclude=db1" ,
2095
2102
"--db-exclude=db5" ,
2096
- "-I" , "checksum" ]))
2103
+ "-I" , "checksum" ])
2097
2104
2098
2105
pgdata2 = self .pgdata_content (node2 .data_dir )
2099
2106
@@ -2198,12 +2205,12 @@ def test_incremental_partial_restore_exclude_lsn(self):
2198
2205
node2 .port = node .port
2199
2206
node2 .slow_start ()
2200
2207
node2 .stop ()
2201
- print ( self .restore_node (
2208
+ self .restore_node (
2202
2209
backup_dir , 'node' ,
2203
2210
node2 , options = [
2204
2211
"--db-exclude=db1" ,
2205
2212
"--db-exclude=db5" ,
2206
- "-I" , "lsn" ]))
2213
+ "-I" , "lsn" ])
2207
2214
2208
2215
pgdata2 = self .pgdata_content (node2 .data_dir )
2209
2216
0 commit comments