@@ -36,6 +36,7 @@ import (
36
36
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
37
37
"k8s.io/apimachinery/pkg/runtime"
38
38
"k8s.io/apimachinery/pkg/runtime/schema"
39
+ "k8s.io/client-go/discovery"
39
40
"k8s.io/client-go/dynamic"
40
41
"k8s.io/client-go/kubernetes"
41
42
"k8s.io/client-go/rest"
@@ -120,8 +121,12 @@ func (gr *GenericResources) Cleanup(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperG
120
121
121
122
_ , apiresourcelist , err := dd .ServerGroupsAndResources ()
122
123
if err != nil {
123
- klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
124
- return name , gvk , err
124
+ if derr , ok := err .(* discovery.ErrGroupDiscoveryFailed ); ok {
125
+ klog .Warning ("Discovery failed for some groups, %d failing: %v" , len (derr .Groups ), err )
126
+ } else {
127
+ klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
128
+ return name , gvk , err
129
+ }
125
130
}
126
131
rsrc := mapping .Resource
127
132
for _ , apiresourcegroup := range apiresourcelist {
@@ -231,8 +236,12 @@ func (gr *GenericResources) SyncQueueJob(aw *arbv1.AppWrapper, awr *arbv1.AppWra
231
236
232
237
_ , apiresourcelist , err := dd .ServerGroupsAndResources ()
233
238
if err != nil {
234
- klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
235
- return []* v1.Pod {}, err
239
+ if derr , ok := err .(* discovery.ErrGroupDiscoveryFailed ); ok {
240
+ klog .Warning ("Discovery failed for some groups, %d failing: %v" , len (derr .Groups ), err )
241
+ } else {
242
+ klog .Errorf ("Error getting supported groups and resources, err=%#v" , err )
243
+ return []* v1.Pod {}, err
244
+ }
236
245
}
237
246
238
247
rsrc := mapping .Resource
0 commit comments