Skip to content

Commit 262bd4f

Browse files
committed
Remove unnecessary refresh agent instances from few requests
Do not refresh agent instances for following server requests: - create agent - should assign work - job completion
1 parent a7cf41c commit 262bd4f

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

src/main/java/cd/go/contrib/elasticagent/KubernetesPlugin.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,12 +79,10 @@ public GoPluginApiResponse handle(GoPluginApiRequest request) {
7979
case REQUEST_CREATE_AGENT:
8080
CreateAgentRequest createAgentRequest = CreateAgentRequest.fromJSON(request.requestBody());
8181
clusterProfileProperties = createAgentRequest.clusterProfileProperties();
82-
refreshInstancesForCluster(clusterProfileProperties);
8382
return createAgentRequest.executor(getAgentInstancesFor(clusterProfileProperties), pluginRequest).execute();
8483
case REQUEST_SHOULD_ASSIGN_WORK:
8584
ShouldAssignWorkRequest shouldAssignWorkRequest = ShouldAssignWorkRequest.fromJSON(request.requestBody());
8685
clusterProfileProperties = shouldAssignWorkRequest.clusterProfileProperties();
87-
refreshInstancesForCluster(clusterProfileProperties);
8886
return shouldAssignWorkRequest.executor(getAgentInstancesFor(clusterProfileProperties)).execute();
8987
case REQUEST_SERVER_PING:
9088
ServerPingRequest serverPingRequest = ServerPingRequest.fromJSON(request.requestBody());
@@ -94,7 +92,6 @@ public GoPluginApiResponse handle(GoPluginApiRequest request) {
9492
case REQUEST_JOB_COMPLETION:
9593
JobCompletionRequest jobCompletionRequest = JobCompletionRequest.fromJSON(request.requestBody());
9694
clusterProfileProperties = jobCompletionRequest.clusterProfileProperties();
97-
refreshInstancesForCluster(clusterProfileProperties);
9895
return jobCompletionRequest.executor(getAgentInstancesFor(clusterProfileProperties), pluginRequest).execute();
9996
case REQUEST_CLUSTER_STATUS_REPORT:
10097
ClusterStatusReportRequest clusterStatusReportRequest = ClusterStatusReportRequest.fromJSON(request.requestBody());

0 commit comments

Comments
 (0)