fix(provider/kubernetes): Fixed an issue with jobProvider failing out…

… other providers.
spinnaker · Jun 22, 2017 · 43688c3 · 43688c3
1 parent 3cce38d
commit 43688c3
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/...y/com/netflix/spinnaker/clouddriver/kubernetes/provider/view/KubernetesJobProvider.groovy b/...y/com/netflix/spinnaker/clouddriver/kubernetes/provider/view/KubernetesJobProvider.groovy
@@ -34,10 +34,14 @@ class KubernetesJobProvider implements JobProvider<KubernetesJobStatus> {
 
   @Override
   KubernetesJobStatus collectJob(String account, String location, String id) {
-    def credentials = ((KubernetesNamedAccountCredentials) accountCredentialsProvider.getCredentials(account)).credentials
-    def status = new KubernetesJobStatus(credentials.apiAdaptor.getPod(location, id), account)
+    def credentials = accountCredentialsProvider.getCredentials(account).credentials
+    if (!credentials instanceof KubernetesNamedAccountCredentials) {
+      return null
+    }
+    def trueCredentials = credentials as KubernetesNamedAccountCredentials
+    def status = new KubernetesJobStatus(trueCredentials.apiAdaptor.getPod(location, id), account)
     if (status.jobState in [JobState.Failed, JobState.Succeeded]) {
-      credentials.apiAdaptor.deletePod(location, id)
+      trueCredentials.apiAdaptor.deletePod(location, id)
     }
     return status
   }