@@ -493,7 +493,7 @@ func TestReconcileDedicatedSnapshotVolume(t *testing.T) {
493
493
t .Cleanup (func () { assert .Check (t , r .Client .Delete (ctx , cluster )) })
494
494
495
495
// Create successful backup job
496
- backupJob := testBackupJob (cluster )
496
+ backupJob := testBackupJob (cluster , "backup-job-snapshots-enabled-1" )
497
497
err = errors .WithStack (r .setControllerReference (cluster , backupJob ))
498
498
assert .NilError (t , err )
499
499
err = r .apply (ctx , backupJob )
@@ -562,7 +562,7 @@ func TestReconcileDedicatedSnapshotVolume(t *testing.T) {
562
562
earlierTime := metav1 .NewTime (currentTime .AddDate (- 1 , 0 , 0 ))
563
563
564
564
// Create successful backup job
565
- backupJob := testBackupJob (cluster )
565
+ backupJob := testBackupJob (cluster , "backup-job-snapshots-enabled-exists-1" )
566
566
err = errors .WithStack (r .setControllerReference (cluster , backupJob ))
567
567
assert .NilError (t , err )
568
568
err = r .apply (ctx , backupJob )
@@ -665,7 +665,7 @@ func TestReconcileDedicatedSnapshotVolume(t *testing.T) {
665
665
earlierTime := metav1 .NewTime (currentTime .AddDate (- 1 , 0 , 0 ))
666
666
667
667
// Create successful backup job
668
- backupJob := testBackupJob (cluster )
668
+ backupJob := testBackupJob (cluster , "backup-job-snapshots-enabled-failed-exists-1" )
669
669
err = errors .WithStack (r .setControllerReference (cluster , backupJob ))
670
670
assert .NilError (t , err )
671
671
err = r .apply (ctx , backupJob )
@@ -796,7 +796,7 @@ func TestDedicatedSnapshotVolumeRestore(t *testing.T) {
796
796
sts := & appsv1.StatefulSet {}
797
797
generateInstanceStatefulSetIntent (ctx , cluster , & cluster .Spec .InstanceSets [0 ], "pod-service" , "service-account" , sts , 1 )
798
798
currentTime := metav1 .Now ()
799
- backupJob := testBackupJob (cluster )
799
+ backupJob := testBackupJob (cluster , "backup-job-dedicated-snapshot-exists-1" )
800
800
backupJob .Status .CompletionTime = & currentTime
801
801
802
802
err := r .dedicatedSnapshotVolumeRestore (ctx , cluster , pvc , backupJob )
@@ -954,7 +954,7 @@ func TestGetLatestCompleteBackupJob(t *testing.T) {
954
954
})
955
955
956
956
t .Run ("NoCompleteJobs" , func (t * testing.T ) {
957
- job1 := testBackupJob (cluster )
957
+ job1 := testBackupJob (cluster , "backup-job-latest-complete-1" )
958
958
job1 .Namespace = ns .Name
959
959
960
960
err := r .apply (ctx , job1 )
@@ -968,15 +968,14 @@ func TestGetLatestCompleteBackupJob(t *testing.T) {
968
968
t .Run ("OneCompleteBackupJob" , func (t * testing.T ) {
969
969
currentTime := metav1 .Now ()
970
970
971
- job1 := testBackupJob (cluster )
971
+ job1 := testBackupJob (cluster , "backup-job-one-complete-1" )
972
972
job1 .Namespace = ns .Name
973
973
974
974
err := r .apply (ctx , job1 )
975
975
assert .NilError (t , err )
976
976
977
- job2 := testBackupJob (cluster )
977
+ job2 := testBackupJob (cluster , "backup-job-one-complete-2" )
978
978
job2 .Namespace = ns .Name
979
- job2 .Name = "backup-job-2"
980
979
981
980
err = r .apply (ctx , job2 )
982
981
assert .NilError (t , err )
@@ -1010,23 +1009,22 @@ func TestGetLatestCompleteBackupJob(t *testing.T) {
1010
1009
1011
1010
latestCompleteBackupJob , err := r .getLatestCompleteBackupJob (ctx , cluster )
1012
1011
assert .NilError (t , err )
1013
- assert .Check (t , latestCompleteBackupJob .Name == "backup-job-1" )
1012
+ assert .Equal (t , latestCompleteBackupJob .Name , "backup-job-one-complete -1" )
1014
1013
})
1015
1014
1016
1015
t .Run ("TwoCompleteBackupJobs" , func (t * testing.T ) {
1017
1016
currentTime := metav1 .Now ()
1018
1017
earlierTime := metav1 .NewTime (currentTime .AddDate (- 1 , 0 , 0 ))
1019
1018
assert .Check (t , earlierTime .Before (& currentTime ))
1020
1019
1021
- job1 := testBackupJob (cluster )
1020
+ job1 := testBackupJob (cluster , "backup-job-two-complete-1" )
1022
1021
job1 .Namespace = ns .Name
1023
1022
1024
1023
err := r .apply (ctx , job1 )
1025
1024
assert .NilError (t , err )
1026
1025
1027
- job2 := testBackupJob (cluster )
1026
+ job2 := testBackupJob (cluster , "backup-job-two-complete-2" )
1028
1027
job2 .Namespace = ns .Name
1029
- job2 .Name = "backup-job-2"
1030
1028
1031
1029
err = r .apply (ctx , job2 )
1032
1030
assert .NilError (t , err )
@@ -1087,7 +1085,7 @@ func TestGetLatestCompleteBackupJob(t *testing.T) {
1087
1085
1088
1086
latestCompleteBackupJob , err := r .getLatestCompleteBackupJob (ctx , cluster )
1089
1087
assert .NilError (t , err )
1090
- assert .Check (t , latestCompleteBackupJob .Name == "backup-job-1" )
1088
+ assert .Equal (t , latestCompleteBackupJob .Name , "backup-job-one-complete -1" )
1091
1089
})
1092
1090
}
1093
1091
0 commit comments