public_git/postgres-operator
1
0
Fork 0
mirror of https://github.com/zalando/postgres-operator.git synced 2026-10-01 15:17:32 +02:00
Code Issues Projects Releases Wiki Activity

keep a single api call

Browse Source
This commit is contained in:
tcondeixa
2026-08-19 09:41:25 +02:00
parent 0e4b4616fc
commit 23c2bc0ba0
1 changed files with 11 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cluster/sync.go
+11 -20
View File
@@ -1783,31 +1783,22 @@ func (c *Cluster) syncLogicalBackupJob() error {
return fmt.Errorf("could not patch labels of the logical backup job %q: %v", jobName, err)
}
}
_, kubeIamInCurrent := job.Annotations[constants.KubeIAmAnnotation]
_, kubeIamInDesired := desiredJob.Annotations[constants.KubeIAmAnnotation]
kubeIamNeedsRemoval := kubeIamInCurrent && !kubeIamInDesired
if changed, _ := c.compareAnnotations(job.Annotations, desiredJob.Annotations, nil); changed || kubeIamNeedsRemoval {
patchAnnotations := make(map[string]interface{})
for k, v := range desiredJob.Annotations {
patchAnnotations[k] = v
}
if kubeIamNeedsRemoval {
patchAnnotations[constants.KubeIAmAnnotation] = nil
}
patchData, err := json.Marshal(map[string]interface{}{
"metadata": map[string]interface{}{"annotations": patchAnnotations},
})
if changed, _ := c.compareAnnotations(job.Annotations, desiredJob.Annotations, nil); changed {
patchData, err := metaAnnotationsPatch(desiredJob.Annotations)
if err != nil {
return fmt.Errorf("could not form patch for the logical backup job %q annotations: %v", jobName, err)
return fmt.Errorf("could not form patch for the logical backup job %q: %v", jobName, err)
}
_, err = c.KubeClient.CronJobs(c.Namespace).Patch(context.TODO(), jobName, types.MergePatchType, patchData, metav1.PatchOptions{})
_, err = c.KubeClient.CronJobs(c.Namespace).Patch(context.TODO(), jobName, types.MergePatchType, []byte(patchData), metav1.PatchOptions{})
if err != nil {
return fmt.Errorf("could not patch annotations of the logical backup job %q: %v", jobName, err)
}
}
if _, ok := job.Spec.JobTemplate.Annotations[constants.KubeIAmAnnotation]; ok {
if _, exists := desiredJob.Spec.JobTemplate.Annotations[constants.KubeIAmAnnotation]; !exists {
if _, ok := job.Annotations[constants.KubeIAmAnnotation]; ok {
if _, exists := desiredJob.Annotations[constants.KubeIAmAnnotation]; !exists {
patchData, err := json.Marshal(map[string]interface{}{
"metadata": map[string]interface{}{
"annotations": map[string]*string{constants.KubeIAmAnnotation: nil},
},
"spec": map[string]interface{}{
"jobTemplate": map[string]interface{}{
"metadata": map[string]interface{}{
@@ -1817,11 +1808,11 @@ func (c *Cluster) syncLogicalBackupJob() error {
},
})
if err != nil {
return fmt.Errorf("could not form patch for the logical backup job %q job template annotations: %v", jobName, err)
return fmt.Errorf("could not form patch to remove kube2iam annotation from logical backup job %q: %v", jobName, err)
}
_, err = c.KubeClient.CronJobs(c.Namespace).Patch(context.TODO(), jobName, types.MergePatchType, patchData, metav1.PatchOptions{})
if err != nil {
return fmt.Errorf("could not remove kube2iam annotation from logical backup job %q job template: %v", jobName, err)
return fmt.Errorf("could not remove kube2iam annotation from logical backup job %q: %v", jobName, err)
}
}
}