github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 19:23:40 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #125825 from p0lyn0mial/upstream-apiextensions-deflake-integration-defaulting-test

Browse Source 
apiextensions-apiserver/test/integration: deflake TestCustomResourceDefaultingWithoutWatchCache
This commit is contained in:
Kubernetes Prow Robot 2024-09-10 17:00:13 +01:00 committed by GitHub
commit 2ede639e57
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
staging/src/k8s.io/apiextensions-apiserver/test/integration/defaulting_test.go
View File

@ -376,8 +376,21 @@ func testDefaulting(t *testing.T, watchCache bool) {
if err != nil {
t.Fatal(err)
}
defer w.Stop()
select {
case event := <-w.ResultChan():
// since the RV we watch from can be compacted
// during the execution of the test,
// tolerate the expiration error.
//
// see: https://github.com/kubernetes/kubernetes/issues/125760
if event.Type == watch.Error {
if !apierrors.IsResourceExpired(apierrors.FromObject(event.Object)) {
t.Fatalf("unexpected watch event: %v, %#v", event.Type, event.Object)
}
t.Logf("skipping the WATCH at RV = %s, because the revision has been compacetd, err: %#v", initialResourceVersion, event.Object)
break
}
if event.Type != watch.Modified {
t.Fatalf("unexpected watch event: %v, %#v", event.Type, event.Object)
}