From f697954c3d7d9c7f575aba7c5b5202c7fe55b457 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jan=20Mu=C3=9Fler?= <janm81@gmail.com>
Date: Wed, 9 Dec 2020 12:20:47 +0100
Subject: [PATCH] store volumes and compare.

---
 pkg/cluster/volumes.go | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/pkg/cluster/volumes.go b/pkg/cluster/volumes.go
index 6de8d6080..597a5a794 100644
--- a/pkg/cluster/volumes.go
+++ b/pkg/cluster/volumes.go
@@ -264,7 +264,21 @@ func (c *Cluster) executeEBSMigration() error {
 
 	volumeIds := []string{}
 	for _, pv := range pvs {
-		volumeIds = append(volumeIds, pv.Spec.AWSElasticBlockStore.VolumeID)
+		volumeID := pv.Spec.AWSElasticBlockStore.VolumeID
+		volumeIds = append(volumeIds, volumeID)
+	}
+
+	if len(volumeIds) == len(c.EBSVolumes) {
+		hasGp2 := false
+		for _, v := range c.EBSVolumes {
+			if v.VolumeType == "gp2" {
+				hasGp2 = true
+			}
+		}
+		if !hasGp2 {
+			// no gp2 volumes left to migrate
+			return nil
+		}
 	}
 
 	awsVolumes, err := c.VolumeResizer.DescribeVolumes(volumeIds)