You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2019/12/19 09:50:09 UTC

[camel-k] 10/10: Fix #921: fix flacky test

This is an automated email from the ASF dual-hosted git repository.

lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git

commit 8a719066009fae5cade8001958ab3ec6708bc1e6
Author: Nicola Ferraro <ni...@gmail.com>
AuthorDate: Thu Dec 19 00:31:20 2019 +0100

    Fix #921: fix flacky test
---
 e2e/test_support.go | 14 ++++++++------
 e2e/upgrade_test.go |  2 +-
 2 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/e2e/test_support.go b/e2e/test_support.go
index b8852bd..a05066d 100644
--- a/e2e/test_support.go
+++ b/e2e/test_support.go
@@ -422,13 +422,15 @@ func deletePlatform(ns string) func() bool {
 	}
 }
 
-func setPlatformVersion(ns string, version string) error {
-	p := platform(ns)()
-	if p == nil {
-		return errors.New("no platform found")
+func setPlatformVersion(ns string, version string) func()error {
+	return func() error {
+		p := platform(ns)()
+		if p == nil {
+			return errors.New("no platform found")
+		}
+		p.Status.Version = version
+		return testClient.Status().Update(testContext, p)
 	}
-	p.Status.Version = version
-	return testClient.Status().Update(testContext, p)
 }
 
 func platformVersion(ns string) func() string {
diff --git a/e2e/upgrade_test.go b/e2e/upgrade_test.go
index 2017670..ede2b5d 100644
--- a/e2e/upgrade_test.go
+++ b/e2e/upgrade_test.go
@@ -40,7 +40,7 @@ func TestPlatformUpgrade(t *testing.T) {
 		Eventually(operatorPod(ns)).Should(BeNil())
 
 		// Change the version to an older one
-		Expect(setPlatformVersion(ns, "an.older.one")).Should(BeNil())
+		Eventually(setPlatformVersion(ns, "an.older.one")).Should(BeNil())
 		Eventually(platformVersion(ns)).Should(Equal("an.older.one"))
 
 		// Scale the operator up