From c059ab75273022f0593f2696264398953f70eed7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Mu=C3=9Fler?= Date: Tue, 23 Feb 2021 21:28:33 +0100 Subject: [PATCH] Log command. --- pkg/cluster/majorversionupgrade.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/cluster/majorversionupgrade.go b/pkg/cluster/majorversionupgrade.go index f930bce7a..aae162ac6 100644 --- a/pkg/cluster/majorversionupgrade.go +++ b/pkg/cluster/majorversionupgrade.go @@ -58,6 +58,7 @@ func (c *Cluster) majorVersionUpgrade() error { if ps.State != "running" { allRunning = false + c.logger.Infof("identified non running pod, potentially skipping major version upgrade") } if ps.Role == "master" { @@ -69,11 +70,13 @@ func (c *Cluster) majorVersionUpgrade() error { numberOfPods := len(pods) if allRunning && masterPod != nil { desiredVersion := c.GetDesiredMajorVersionAsInt() - c.logger.Infof("cluster healthy with version: %d desired: %d", c.currentMajorVersion, desiredVersion) + c.logger.Infof("healthy cluster, version: %d desired: %d", c.currentMajorVersion, desiredVersion) if c.currentMajorVersion < desiredVersion { podName := &spec.NamespacedName{Namespace: masterPod.Namespace, Name: masterPod.Name} c.logger.Infof("triggering major version upgrade on pod %s", masterPod.Name) - _, err := c.ExecCommand(podName, fmt.Sprintf("su postgres -c \"python3 /scripts/inplace_upgrade.py %d 2>&1 | tee last_upgrade.log\"", numberOfPods)) + command := fmt.Sprintf("su postgres -c \"python3 /scripts/inplace_upgrade.py %d 2>&1 | tee last_upgrade.log\"", numberOfPods) + c.logger.Info("executing: %s", command) + _, err := c.ExecCommand(podName, command) if err != nil { return err }