From 7f72eeadcf836d6dfed4a5f1133e989a9716db4b Mon Sep 17 00:00:00 2001 From: Abhishek Malvankar Date: Fri, 21 Jul 2023 08:58:31 -0400 Subject: [PATCH] remove resource discovery failures (#495) * remove resource discovery failures * address review --- .../genericresource/genericresource.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/pkg/controller/queuejobresources/genericresource/genericresource.go b/pkg/controller/queuejobresources/genericresource/genericresource.go index 4b2879305..1336b040d 100644 --- a/pkg/controller/queuejobresources/genericresource/genericresource.go +++ b/pkg/controller/queuejobresources/genericresource/genericresource.go @@ -36,6 +36,7 @@ import ( "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" + "k8s.io/client-go/discovery" "k8s.io/client-go/dynamic" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" @@ -120,8 +121,12 @@ func (gr *GenericResources) Cleanup(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperG _, apiresourcelist, err := dd.ServerGroupsAndResources() if err != nil { - klog.Errorf("Error getting supported groups and resources, err=%#v", err) - return name, gvk, err + if derr, ok := err.(*discovery.ErrGroupDiscoveryFailed); ok { + klog.Warning("Discovery failed for some groups, %d failing: %v", len(derr.Groups), err) + } else { + klog.Errorf("Error getting supported groups and resources, err=%#v", err) + return name, gvk, err + } } rsrc := mapping.Resource for _, apiresourcegroup := range apiresourcelist { @@ -233,8 +238,12 @@ func (gr *GenericResources) SyncQueueJob(aw *arbv1.AppWrapper, awr *arbv1.AppWra _, apiresourcelist, err := dd.ServerGroupsAndResources() if err != nil { - klog.Errorf("Error getting supported groups and resources, err=%#v", err) - return []*v1.Pod{}, err + if derr, ok := err.(*discovery.ErrGroupDiscoveryFailed); ok { + klog.Warning("Discovery failed for some groups, %d failing: %v", len(derr.Groups), err) + } else { + klog.Errorf("Error getting supported groups and resources, err=%#v", err) + return []*v1.Pod{}, err + } } rsrc := mapping.Resource