This is an automated email from the ASF dual-hosted git repository.
squakez pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/main by this push:
new a2719dcd3 chore(e2e): replace expect with eventually
a2719dcd3 is described below
commit a2719dcd3093887a6b98db80d6f4a4465e0e4b5f
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Fri Aug 14 14:44:12 2026 +0200
chore(e2e): replace expect with eventually
---
e2e/common/misc/pipe_test.go | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/e2e/common/misc/pipe_test.go b/e2e/common/misc/pipe_test.go
index 2402919b6..ea405fa5e 100644
--- a/e2e/common/misc/pipe_test.go
+++ b/e2e/common/misc/pipe_test.go
@@ -162,7 +162,9 @@ func TestPipeScale(t *testing.T) {
g.Expect(err).To(BeNil())
// Check the readiness condition is still truthy as
down-scaling
- g.Expect(PipeConditionStatus(t, ctx, ns, name,
v1.PipeConditionReady)()).To(Equal(corev1.ConditionTrue))
+ g.Eventually(
+ PipeConditionStatus(t, ctx, ns, name,
v1.PipeConditionReady),
+ ).Should(Equal(corev1.ConditionTrue))
// Check the Integration scale subresource Spec field
g.Eventually(IntegrationSpecReplicas(t, ctx, ns, name),
TestTimeoutShort).
Should(gstruct.PointTo(BeNumerically("==", 2)))
@@ -192,12 +194,16 @@ func TestPipeScale(t *testing.T) {
g.Expect(err).To(BeNil())
// Check the readiness condition is still truthy as
down-scaling inPipe
- g.Expect(PipeConditionStatus(t, ctx, ns, name,
v1.PipeConditionReady)()).To(Equal(corev1.ConditionTrue))
+ g.Eventually(
+ PipeConditionStatus(t, ctx, ns, name,
v1.PipeConditionReady),
+ ).Should(Equal(corev1.ConditionTrue))
// Check the Pipe scale subresource Spec field
g.Eventually(PipeSpecReplicas(t, ctx, ns, name),
TestTimeoutShort).
Should(gstruct.PointTo(BeNumerically("==", 1)))
// Check the readiness condition is still truthy as
down-scaling
- g.Expect(IntegrationConditionStatus(t, ctx, ns, name,
v1.IntegrationConditionReady)()).To(Equal(corev1.ConditionTrue))
+ g.Eventually(
+ IntegrationConditionStatus(t, ctx, ns, name,
v1.IntegrationConditionReady),
+ ).To(Equal(corev1.ConditionTrue))
// Check the Integration scale subresource Spec field
g.Eventually(IntegrationSpecReplicas(t, ctx, ns, name),
TestTimeoutShort).
Should(gstruct.PointTo(BeNumerically("==", 1)))
