fix(provider/kubernetes): tolerate per namespace failures (#2435)

spinnaker · Mar 20, 2018 · 9be993c · 9be993c
1 parent c1999cf
commit 9be993c
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...m/netflix/spinnaker/clouddriver/kubernetes/v2/caching/agent/KubernetesV2CachingAgent.java b/...m/netflix/spinnaker/clouddriver/kubernetes/v2/caching/agent/KubernetesV2CachingAgent.java
@@ -29,6 +29,7 @@
 import com.netflix.spinnaker.clouddriver.kubernetes.v2.description.manifest.KubernetesKind;
 import com.netflix.spinnaker.clouddriver.kubernetes.v2.description.manifest.KubernetesManifest;
 import com.netflix.spinnaker.clouddriver.kubernetes.v2.op.job.KubectlJobExecutor;
+import com.netflix.spinnaker.clouddriver.kubernetes.v2.op.job.KubectlJobExecutor.KubectlException;
 import com.netflix.spinnaker.clouddriver.kubernetes.v2.security.KubernetesV2Credentials;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
@@ -65,7 +66,15 @@ protected boolean hasClusterRelationship() {
 
   protected List<KubernetesManifest> loadPrimaryResourceList() {
     return namespaces.stream()
-        .map(n -> credentials.list(primaryKind(), n))
+        .map(n -> {
+          try {
+            return credentials.list(primaryKind(), n);
+          } catch (KubectlException e) {
+            log.warn("Failed to read kind {} from namespace {}: {}", primaryKind(), n, e.getMessage());
+            return null;
+          }
+        })
+        .filter(Objects::nonNull)
         .flatMap(Collection::stream)
         .collect(Collectors.toList());
   }