diff --git a/pkg/controller/direct/export.go b/pkg/controller/direct/export.go index c17e43e826..ead3dcecb7 100644 --- a/pkg/controller/direct/export.go +++ b/pkg/controller/direct/export.go @@ -17,6 +17,7 @@ package direct import ( "context" "fmt" + "strings" "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/config" "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/controller/direct/registry" @@ -42,6 +43,9 @@ func Export(ctx context.Context, url string, config *config.ControllerConfig) (* u, err := adapter.Export(ctx) if err != nil { + if strings.Contains(err.Error(), "not supported") { + return nil, nil + } return nil, err } diff --git a/pkg/controller/direct/registry/registry.go b/pkg/controller/direct/registry/registry.go index 8b05546ef6..a9b4bc1af2 100644 --- a/pkg/controller/direct/registry/registry.go +++ b/pkg/controller/direct/registry/registry.go @@ -17,6 +17,7 @@ package registry import ( "context" "fmt" + "strings" "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/config" "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/controller/direct/directbase" @@ -62,8 +63,11 @@ func AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error) } adapter, err := registration.model.AdapterForURL(ctx, url) if err != nil { - return nil, err + if !strings.Contains(err.Error(), "not supported") { + return nil, err + } } + if adapter != nil { return adapter, nil }