Skip to content

Commit 447e590

Browse files
Merge pull request #19824 from mrogers950/sa-event-flake
Add an event poll for TestOAuthServiceAccountClientEvent
2 parents 6d89588 + 5460a8e commit 447e590

File tree

1 file changed

+16
-4
lines changed

1 file changed

+16
-4
lines changed

test/integration/oauth_serviceaccount_client_events_test.go

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package integration
22

33
import (
4-
"golang.org/x/net/html"
54
"net/http"
65
"net/http/cookiejar"
76
"net/http/httptest"
@@ -10,6 +9,8 @@ import (
109
"testing"
1110
"time"
1211

12+
"golang.org/x/net/html"
13+
1314
"github.com/RangelReale/osincli"
1415

1516
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -151,10 +152,21 @@ func TestOAuthServiceAccountClientEvent(t *testing.T) {
151152

152153
runTestOAuthFlow(t, testServer, sa, secret, redirect, testCase.expectBadRequest)
153154

154-
// Check events
155-
evList, err := testServer.clusterAdminKubeClient.Core().Events(projectName).List(metav1.ListOptions{})
155+
// Check events with a short poll to stop flakes
156+
var evList *kapi.EventList
157+
err = wait.Poll(time.Second, 5*time.Second, func() (bool, error) {
158+
evList, err = testServer.clusterAdminKubeClient.Core().Events(projectName).List(metav1.ListOptions{})
159+
if err != nil {
160+
return false, err
161+
}
162+
if len(evList.Items) < testCase.numEvents {
163+
return false, nil
164+
}
165+
return true, nil
166+
})
167+
156168
if err != nil {
157-
t.Fatalf("%s: err listing events", tcName)
169+
t.Fatalf("%s: err polling for events", tcName)
158170
}
159171

160172
events := collectEventsWithReason(evList, testCase.expectedEventReason)

0 commit comments

Comments
 (0)