Skip to content

Commit 4862c9b

Browse files
hellolittlejggao
andauthored
Fix inconsitent return type for the delete jobcluster (#810)
Co-authored-by: ggao <ggao@netflix.com>
1 parent 4ef1ba1 commit 4862c9b

File tree

2 files changed

+21
-10
lines changed

2 files changed

+21
-10
lines changed

mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java

Lines changed: 20 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -467,17 +467,28 @@ private Route deleteJobClusterInstanceRoute(String clusterName) {
467467
return parameterOptional("user", user -> {
468468
logger.info("DELETE /api/v1/jobClusters/{} called", clusterName);
469469

470-
String userStr = user.orElse(null);
471-
if (Strings.isNullOrEmpty(userStr)) {
472-
return complete(StatusCodes.BAD_REQUEST, "Missing required parameter 'user'");
473-
} else {
474-
return completeAsync(
475-
jobClusterRouteHandler.delete(new DeleteJobClusterRequest(userStr, clusterName)),
476-
resp -> complete(StatusCodes.ACCEPTED, ""),
477-
HttpRequestMetrics.Endpoints.JOB_CLUSTER_INSTANCE,
478-
HttpRequestMetrics.HttpVerb.DELETE
470+
CompletionStage<JobClusterManagerProto.DeleteJobClusterResponse> deleteResponse;
471+
472+
if (user.isEmpty()) {
473+
CompletableFuture<JobClusterManagerProto.DeleteJobClusterResponse> resp = new CompletableFuture<>();
474+
resp.complete(
475+
new JobClusterManagerProto.DeleteJobClusterResponse(
476+
-1L,
477+
BaseResponse.ResponseCode.CLIENT_ERROR,
478+
"Missing required query parameter 'user'"
479+
)
479480
);
481+
deleteResponse = resp;
482+
} else {
483+
deleteResponse = jobClusterRouteHandler.delete(new DeleteJobClusterRequest(user.get(), clusterName));
480484
}
485+
486+
return completeAsync(
487+
deleteResponse,
488+
resp -> complete(StatusCodes.NO_CONTENT, ""),
489+
HttpRequestMetrics.Endpoints.JOB_CLUSTER_INSTANCE,
490+
HttpRequestMetrics.HttpVerb.DELETE
491+
);
481492
});
482493
}
483494

mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/api/akka/route/v1/JobClustersRouteTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -673,7 +673,7 @@ private void testJobClusterValidDelete() throws InterruptedException {
673673
assert isClusterExist("sine-function");
674674

675675
testDelete(getJobClusterInstanceEndpoint("sine-function") + "?user=test&reason=unittest",
676-
StatusCodes.ACCEPTED, null);
676+
StatusCodes.NO_CONTENT, null);
677677
boolean clusterExist = isClusterExist("sine-function");
678678
int retry = 10;
679679
while (clusterExist && retry > 0) {

0 commit comments

Comments
 (0)