From 249db7ceb39bfa3ecdb175aec4ddf22242432ba4 Mon Sep 17 00:00:00 2001 From: Antonio Ojea Date: Tue, 22 Jun 2021 01:49:24 +0200 Subject: [PATCH] wait for endpoints to be available --- test/e2e/framework/service/jig.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/test/e2e/framework/service/jig.go b/test/e2e/framework/service/jig.go index 7b5e9ebb492..b9f877ebccf 100644 --- a/test/e2e/framework/service/jig.go +++ b/test/e2e/framework/service/jig.go @@ -304,6 +304,10 @@ func (j *TestJig) ListNodesWithEndpoint() ([]v1.Node, error) { // GetEndpointNodeNames returns a string set of node names on which the // endpoints of the given Service are running. func (j *TestJig) GetEndpointNodeNames() (sets.String, error) { + err := j.waitForAvailableEndpoint(ServiceEndpointsTimeout) + if err != nil { + return nil, err + } endpoints, err := j.Client.CoreV1().Endpoints(j.Namespace).Get(context.TODO(), j.Name, metav1.GetOptions{}) if err != nil { return nil, fmt.Errorf("get endpoints for service %s/%s failed (%s)", j.Namespace, j.Name, err)