@@ -582,7 +582,7 @@ func (r *PerconaServerMySQLHibernationReconciler) pauseCluster(ctx context.Conte
582
582
return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
583
583
// Get fresh copy of the cluster
584
584
fresh := & apiv1.PerconaServerMySQL {}
585
- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
585
+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
586
586
log .Error (err , "Failed to get fresh cluster copy" , "cluster" , cr .Name , "namespace" , cr .Namespace )
587
587
return err
588
588
}
@@ -591,7 +591,7 @@ func (r *PerconaServerMySQLHibernationReconciler) pauseCluster(ctx context.Conte
591
591
fresh .Spec .Pause = true
592
592
593
593
// Update the cluster
594
- if err := r .Client . Update (ctx , fresh ); err != nil {
594
+ if err := r .Update (ctx , fresh ); err != nil {
595
595
log .Error (err , "Failed to update cluster spec" , "cluster" , cr .Name , "namespace" , cr .Namespace )
596
596
return err
597
597
}
@@ -632,7 +632,7 @@ func (r *PerconaServerMySQLHibernationReconciler) unpauseCluster(ctx context.Con
632
632
return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
633
633
// Get fresh copy of the cluster
634
634
fresh := & apiv1.PerconaServerMySQL {}
635
- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
635
+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
636
636
log .Error (err , "Failed to get fresh cluster copy" , "cluster" , cr .Name , "namespace" , cr .Namespace )
637
637
return err
638
638
}
@@ -641,7 +641,7 @@ func (r *PerconaServerMySQLHibernationReconciler) unpauseCluster(ctx context.Con
641
641
fresh .Spec .Pause = false
642
642
643
643
// Update the cluster
644
- if err := r .Client . Update (ctx , fresh ); err != nil {
644
+ if err := r .Update (ctx , fresh ); err != nil {
645
645
log .Error (err , "Failed to update cluster spec" , "cluster" , cr .Name , "namespace" , cr .Namespace )
646
646
return err
647
647
}
@@ -682,7 +682,7 @@ func (r *PerconaServerMySQLHibernationReconciler) updateHibernationState(ctx con
682
682
return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
683
683
// Get fresh copy of the cluster
684
684
fresh := & apiv1.PerconaServerMySQL {}
685
- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
685
+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
686
686
log .Error (err , "Failed to get fresh cluster copy for status update" , "cluster" , cr .Name , "namespace" , cr .Namespace )
687
687
return err
688
688
}
@@ -725,7 +725,7 @@ func (r *PerconaServerMySQLHibernationReconciler) initializeHibernationStatus(ct
725
725
return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
726
726
// Get fresh copy of the cluster
727
727
fresh := & apiv1.PerconaServerMySQL {}
728
- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
728
+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
729
729
log .Error (err , "Failed to get fresh cluster copy for status initialization" , "cluster" , cr .Name , "namespace" , cr .Namespace )
730
730
return err
731
731
}
@@ -866,7 +866,7 @@ func (r *PerconaServerMySQLHibernationReconciler) updateHibernationNextTimes(ctx
866
866
return k8sretry .RetryOnConflict (k8sretry .DefaultRetry , func () error {
867
867
// Get fresh copy of the cluster
868
868
fresh := & apiv1.PerconaServerMySQL {}
869
- if err := r .Client . Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
869
+ if err := r .Get (ctx , types.NamespacedName {Name : cr .Name , Namespace : cr .Namespace }, fresh ); err != nil {
870
870
log .Error (err , "Failed to get fresh cluster copy for schedule update" , "cluster" , cr .Name , "namespace" , cr .Namespace )
871
871
return err
872
872
}
0 commit comments