From cff0f69dd02e05c72afcba5db4e48fab9df9c2bc Mon Sep 17 00:00:00 2001
From: Jan Mussler <jan.mussler@zalando.de>
Date: Tue, 6 Feb 2024 15:23:00 +0100
Subject: [PATCH] Recheck version from Patroni IP.

---
 pkg/cluster/majorversionupgrade.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/pkg/cluster/majorversionupgrade.go b/pkg/cluster/majorversionupgrade.go
index 19813fedc..ae926d85e 100644
--- a/pkg/cluster/majorversionupgrade.go
+++ b/pkg/cluster/majorversionupgrade.go
@@ -17,6 +17,7 @@ var VersionMap = map[string]int{
 	"13": 130000,
 	"14": 140000,
 	"15": 150000,
+	"16": 160000,
 }
 
 // IsBiggerPostgresVersion Compare two Postgres version numbers
@@ -97,6 +98,12 @@ func (c *Cluster) majorVersionUpgrade() error {
 		}
 	}
 
+	// Recheck version with newest data from Patroni
+	if c.currentMajorVersion >= desiredVersion {
+		c.logger.Infof("recheck cluster version is already up to date. current: %d, min desired: %d", c.currentMajorVersion, desiredVersion)
+		return nil
+	}
+
 	numberOfPods := len(pods)
 	if allRunning && masterPod != nil {
 		c.logger.Infof("healthy cluster ready to upgrade, current: %d desired: %d", c.currentMajorVersion, desiredVersion)