Skip to content

Commit 42f39b5

Browse files
author
Emruz Hossain
authored
Fix label passing to backup/restore jobs (#1470)
Signed-off-by: Emruz Hossain <emruz@appscode.com>
1 parent 2b445ce commit 42f39b5

File tree

2 files changed

+6
-9
lines changed

2 files changed

+6
-9
lines changed

pkg/controller/backup_session.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -464,9 +464,9 @@ func (c *StashController) ensureBackupJob(inv invoker.BackupInvoker, targetInfo
464464
// set BackupSession as owner of this Job so that it get cleaned automatically
465465
// when the BackupSession gets deleted according to backupHistoryLimit
466466
core_util.EnsureOwnerReference(&in.ObjectMeta, ownerBackupSession)
467-
// pass offshoot labels to job's pod
468-
in.Spec.Template.Labels = meta_util.OverwriteKeys(in.Spec.Template.Labels, inv.GetLabels())
467+
469468
in.Spec.Template.Spec = podSpec
469+
in.Spec.Template.Labels = meta_util.OverwriteKeys(in.Spec.Template.Labels, inv.GetLabels())
470470
in.Spec.Template.Spec.ImagePullSecrets = core_util.MergeLocalObjectReferences(in.Spec.Template.Spec.ImagePullSecrets, imagePullSecrets)
471471
in.Spec.Template.Spec.ServiceAccountName = rbacOptions.ServiceAccount.Name
472472
in.Spec.BackoffLimit = pointer.Int32P(0)
@@ -543,9 +543,7 @@ func (c *StashController) ensureVolumeSnapshotterJob(inv invoker.BackupInvoker,
543543
// when the BackupSession gets deleted according to backupHistoryLimit
544544
core_util.EnsureOwnerReference(&in.ObjectMeta, ownerBackupSession)
545545

546-
in.Labels = inv.GetLabels()
547-
in.Spec.Template = *jobTemplate
548-
// pass offshoot labels to job's pod
546+
in.Spec.Template.Spec = jobTemplate.Spec
549547
in.Spec.Template.Labels = meta_util.OverwriteKeys(in.Spec.Template.Labels, inv.GetLabels())
550548
in.Spec.Template.Spec.ImagePullSecrets = core_util.MergeLocalObjectReferences(in.Spec.Template.Spec.ImagePullSecrets, imagePullSecrets)
551549
in.Spec.Template.Spec.ServiceAccountName = rbacOptions.ServiceAccount.Name

pkg/controller/restore_session.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -554,7 +554,8 @@ func (c *StashController) createRestoreJob(jobTemplate *core.PodTemplateSpec, me
554554
// set RestoreSession as owner of this Job
555555
core_util.EnsureOwnerReference(&in.ObjectMeta, owner)
556556

557-
in.Spec.Template = *jobTemplate
557+
in.Spec.Template.Spec = jobTemplate.Spec
558+
in.Spec.Template.Labels = meta_util.OverwriteKeys(in.Spec.Template.Labels, jobTemplate.Labels)
558559
in.Spec.BackoffLimit = pointer.Int32P(0)
559560
return in
560561
},
@@ -685,9 +686,7 @@ func (c *StashController) ensureVolumeRestorerJob(inv invoker.RestoreInvoker, in
685686
// set restore invoker as owner of this Job
686687
core_util.EnsureOwnerReference(&in.ObjectMeta, inv.GetOwnerRef())
687688

688-
in.Labels = inv.GetLabels()
689-
in.Spec.Template = *jobTemplate
690-
// pass offshoot labels to job's pod
689+
in.Spec.Template.Spec = jobTemplate.Spec
691690
in.Spec.Template.Labels = meta_util.OverwriteKeys(in.Spec.Template.Labels, inv.GetLabels())
692691
in.Spec.Template.Spec.ImagePullSecrets = core_util.MergeLocalObjectReferences(in.Spec.Template.Spec.ImagePullSecrets, imagePullSecrets)
693692
in.Spec.Template.Spec.ServiceAccountName = rbacOptions.ServiceAccount.Name

0 commit comments

Comments
 (0)