Reinitialize agent instances if those are null

GaneshSPatil · GaneshSPatil · commit 839613e8d494 · 2019-07-30T12:05:11.000+05:30
diff --git a/src/main/java/cd/go/contrib/elasticagent/KubernetesPlugin.java b/src/main/java/cd/go/contrib/elasticagent/KubernetesPlugin.java
@@ -122,8 +122,15 @@ private void refreshInstancesForAllClusters(List<ClusterProfileProperties> listO
         }
     }
 
-    private AgentInstances<KubernetesInstance> getAgentInstancesFor(ClusterProfileProperties clusterProfileProperties) {
-        return clusterSpecificAgentInstances.get(clusterProfileProperties.uuid());
+    private AgentInstances<KubernetesInstance> getAgentInstancesFor(ClusterProfileProperties clusterProfileProperties) throws Exception {
+        KubernetesAgentInstances agentInstances = clusterSpecificAgentInstances.get(clusterProfileProperties.uuid());
+
+        //initalize agent instances if those are null
+        if (agentInstances == null) {
+            refreshInstancesForCluster(clusterProfileProperties);
+        }
+
+        return agentInstances;
     }
 
     private void refreshInstancesForCluster(ClusterProfileProperties clusterProfileProperties) throws Exception {

Original file line number	Diff line number	Diff line change
`@@ -122,8 +122,15 @@ private void refreshInstancesForAllClusters(List<ClusterProfileProperties> listO`
`122`	`122`	`}`
`123`	`123`	`}`
`124`	`124`
`125`		`- private AgentInstances<KubernetesInstance> getAgentInstancesFor(ClusterProfileProperties clusterProfileProperties) {`
`126`		`- return clusterSpecificAgentInstances.get(clusterProfileProperties.uuid());`
	`125`	`+ private AgentInstances<KubernetesInstance> getAgentInstancesFor(ClusterProfileProperties clusterProfileProperties) throws Exception {`
	`126`	`+ KubernetesAgentInstances agentInstances = clusterSpecificAgentInstances.get(clusterProfileProperties.uuid());`
	`127`	`+`
	`128`	`+ //initalize agent instances if those are null`
	`129`	`+ if (agentInstances == null) {`
	`130`	`+ refreshInstancesForCluster(clusterProfileProperties);`
	`131`	`+ }`
	`132`	`+`
	`133`	`+ return agentInstances;`
`127`	`134`	`}`
`128`	`135`
`129`	`136`	`private void refreshInstancesForCluster(ClusterProfileProperties clusterProfileProperties) throws Exception {`