fix(upgrade): label all pods correctly

k-web-s · Mar 23, 2024 · 40a7b11 · 40a7b11
1 parent ff4ef96
commit 40a7b11
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/private/upgrade/common.go b/private/upgrade/common.go
@@ -57,6 +57,9 @@ func createUpgradeJob(ctx pcontext.Context, p *v1alpha1.PatroniPostgres, mode st
 			ActiveDeadlineSeconds: &activeDeadlineSeconds,
 			Completions:           &completions,
 			Template: v1.PodTemplateSpec{
+				ObjectMeta: metav1.ObjectMeta{
+					Labels: ctx.CommonLabels(),
+				},
 				Spec: v1.PodSpec{
 					Containers: []v1.Container{
 						{

diff --git a/private/upgrade/primary.go b/private/upgrade/primary.go
@@ -108,6 +108,9 @@ func (primaryUpgradeHandler) handle(ctx pcontext.Context, p *v1alpha1.PatroniPos
 				ActiveDeadlineSeconds: &activeDeadlineSeconds,
 				Completions:           &completions,
 				Template: v1.PodTemplateSpec{
+					ObjectMeta: metav1.ObjectMeta{
+						Labels: ctx.CommonLabels(),
+					},
 					Spec: v1.PodSpec{
 						Containers: []v1.Container{
 							{

diff --git a/private/upgrade/secondary-client.go b/private/upgrade/secondary-client.go
@@ -74,6 +74,9 @@ func upgradeSecondariesEnsureseclients(ctx pcontext.Context, p *v1alpha1.Patroni
 					ActiveDeadlineSeconds: &activeDeadlineSeconds,
 					Completions:           &completions,
 					Template: v1.PodTemplateSpec{
+						ObjectMeta: metav1.ObjectMeta{
+							Labels: ctx.CommonLabels(),
+						},
 						Spec: v1.PodSpec{
 							Containers: []v1.Container{
 								{