From 16c14b3098c5eb04ffb80704ecf68371e04619be Mon Sep 17 00:00:00 2001
From: Sergey Dudoladov <sergey.dudoladov@zalando.de>
Date: Wed, 14 Oct 2020 09:01:12 +0200
Subject: [PATCH] make Sync take PGVERSION into account

---
 pkg/cluster/k8sres.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/pkg/cluster/k8sres.go b/pkg/cluster/k8sres.go
index ed5efaf84..333da650b 100644
--- a/pkg/cluster/k8sres.go
+++ b/pkg/cluster/k8sres.go
@@ -916,10 +916,20 @@ func (c *Cluster) getNewPgVersion(container v1.Container, newPgVersion string) (
 	var (
 		spiloConfiguration spiloConfiguration
 		runningPgVersion   string
+		version            string
 		err                error
 	)
 
 	for _, env := range container.Env {
+
+		if env.Name == "PGVERSION" {
+			err = json.Unmarshal([]byte(env.Value), &version)
+			if err != nil {
+				return newPgVersion, err
+			}
+			return version, nil
+		}
+
 		if env.Name != "SPILO_CONFIGURATION" {
 			continue
 		}