@@ -3546,7 +3546,7 @@ def test_start_time_incorrect_time(self):
3546
3546
3547
3547
# @unittest.skip("skip")
3548
3548
def test_start_time_few_nodes (self ):
3549
-
3549
+ """Test, that we can synchronize backup_id's for different DBs"""
3550
3550
fname = self .id ().split ('.' )[3 ]
3551
3551
node1 = self .make_simple_node (
3552
3552
base_dir = os .path .join (module_name , fname , 'node1' ),
@@ -3571,62 +3571,60 @@ def test_start_time_few_nodes(self):
3571
3571
node2 .slow_start ()
3572
3572
3573
3573
# FULL backup
3574
- startTime = int (time ())
3574
+ startTime = str ( int (time () ))
3575
3575
self .backup_node (
3576
- backup_dir1 , 'node1' , node1 , backup_type = " full" ,
3577
- options = ['--stream' , '--start-time' , str (startTime )])
3576
+ backup_dir1 , 'node1' , node1 , backup_type = ' full' ,
3577
+ options = ['--stream' , '--start-time={0}' . format (startTime )])
3578
3578
self .backup_node (
3579
- backup_dir2 , 'node2' , node2 , backup_type = "full" ,
3580
- options = ['--stream' , '--start-time' , str (startTime )])
3581
-
3579
+ backup_dir2 , 'node2' , node2 , backup_type = 'full' ,
3580
+ options = ['--stream' , '--start-time={0}' .format (startTime )])
3582
3581
show_backup1 = self .show_pb (backup_dir1 , 'node1' )[0 ]
3583
3582
show_backup2 = self .show_pb (backup_dir2 , 'node2' )[0 ]
3584
3583
self .assertEqual (show_backup1 ['id' ], show_backup2 ['id' ])
3585
3584
3586
3585
# DELTA backup
3587
- startTime = int (time ())
3586
+ startTime = str ( int (time () ))
3588
3587
self .backup_node (
3589
- backup_dir1 , 'node1' , node1 , backup_type = " delta" ,
3590
- options = ['--stream' , '--start-time' , str (startTime )])
3588
+ backup_dir1 , 'node1' , node1 , backup_type = ' delta' ,
3589
+ options = ['--stream' , '--start-time={0}' . format (startTime )])
3591
3590
self .backup_node (
3592
- backup_dir2 , 'node2' , node2 , backup_type = " delta" ,
3593
- options = ['--stream' , '--start-time' , str (startTime )])
3591
+ backup_dir2 , 'node2' , node2 , backup_type = ' delta' ,
3592
+ options = ['--stream' , '--start-time={0}' . format (startTime )])
3594
3593
show_backup1 = self .show_pb (backup_dir1 , 'node1' )[1 ]
3595
3594
show_backup2 = self .show_pb (backup_dir2 , 'node2' )[1 ]
3596
3595
self .assertEqual (show_backup1 ['id' ], show_backup2 ['id' ])
3597
3596
3598
3597
# PAGE backup
3599
- startTime = int (time ())
3598
+ startTime = str ( int (time () ))
3600
3599
self .backup_node (
3601
- backup_dir1 , 'node1' , node1 , backup_type = " page" ,
3602
- options = ['--stream' , '--start-time' , str (startTime )])
3600
+ backup_dir1 , 'node1' , node1 , backup_type = ' page' ,
3601
+ options = ['--stream' , '--start-time={0}' . format (startTime )])
3603
3602
self .backup_node (
3604
- backup_dir2 , 'node2' , node2 , backup_type = " page" ,
3605
- options = ['--stream' , '--start-time' , str (startTime )])
3603
+ backup_dir2 , 'node2' , node2 , backup_type = ' page' ,
3604
+ options = ['--stream' , '--start-time={0}' . format (startTime )])
3606
3605
show_backup1 = self .show_pb (backup_dir1 , 'node1' )[2 ]
3607
3606
show_backup2 = self .show_pb (backup_dir2 , 'node2' )[2 ]
3608
3607
self .assertEqual (show_backup1 ['id' ], show_backup2 ['id' ])
3609
3608
3610
3609
# PTRACK backup
3611
- startTime = int (time ())
3612
- if self .ptrack and node1 .major_version > 11 :
3610
+ if self .ptrack :
3613
3611
node1 .safe_psql (
3614
- "postgres" ,
3615
- "create extension ptrack" )
3616
- self .backup_node (
3617
- backup_dir1 , 'node1' , node1 , backup_type = "ptrack" ,
3618
- options = ['--stream' , '--start-time' , str (startTime )])
3619
-
3620
- if self .ptrack and node2 .major_version > 11 :
3612
+ 'postgres' ,
3613
+ 'create extension ptrack' )
3621
3614
node2 .safe_psql (
3622
- "postgres" ,
3623
- "create extension ptrack" )
3615
+ 'postgres' ,
3616
+ 'create extension ptrack' )
3617
+
3618
+ startTime = str (int (time ()))
3624
3619
self .backup_node (
3625
- backup_dir2 , 'node2' , node2 , backup_type = "ptrack" ,
3626
- options = ['--stream' , '--start-time' , str (startTime )])
3627
- show_backup1 = self .show_pb (backup_dir1 , 'node1' )[3 ]
3628
- show_backup2 = self .show_pb (backup_dir2 , 'node2' )[3 ]
3629
- self .assertEqual (show_backup1 ['id' ], show_backup2 ['id' ])
3620
+ backup_dir1 , 'node1' , node1 , backup_type = 'ptrack' ,
3621
+ options = ['--stream' , '--start-time={0}' .format (startTime )])
3622
+ self .backup_node (
3623
+ backup_dir2 , 'node2' , node2 , backup_type = 'ptrack' ,
3624
+ options = ['--stream' , '--start-time={0}' .format (startTime )])
3625
+ show_backup1 = self .show_pb (backup_dir1 , 'node1' )[3 ]
3626
+ show_backup2 = self .show_pb (backup_dir2 , 'node2' )[3 ]
3627
+ self .assertEqual (show_backup1 ['id' ], show_backup2 ['id' ])
3630
3628
3631
3629
# Clean after yourself
3632
3630
self .del_test_dir (module_name , fname )
0 commit comments