Skip to content

Commit a7c78ee

Browse files
committed
Fix delete job
1 parent 417624f commit a7c78ee

File tree

1 file changed

+8
-5
lines changed
  • x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job

1 file changed

+8
-5
lines changed

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/JobManager.java

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import org.elasticsearch.ResourceAlreadyExistsException;
1111
import org.elasticsearch.ResourceNotFoundException;
1212
import org.elasticsearch.action.ActionListener;
13+
import org.elasticsearch.action.DocWriteResponse;
1314
import org.elasticsearch.action.index.IndexResponse;
1415
import org.elasticsearch.action.support.WriteRequest;
1516
import org.elasticsearch.client.Client;
@@ -336,15 +337,17 @@ public void markJobAsDeleting(String jobId, boolean force, ActionListener<Boolea
336337
*/
337338
public void deleteJob(DeleteJobAction.Request request, ActionListener<Boolean> listener) {
338339
jobConfigProvider.deleteJob(request.getJobId(), false, ActionListener.wrap(
339-
deleteResponse -> listener.onResponse(Boolean.TRUE),
340-
e -> {
341-
if (e.getClass() == ResourceNotFoundException.class) {
340+
deleteResponse -> {
341+
if (deleteResponse.getResult() == DocWriteResponse.Result.NOT_FOUND) {
342342
if (ClusterStateJobUpdate.jobIsInClusterState(clusterService.state(), request.getJobId())) {
343343
ClusterStateJobUpdate.deleteJob(request, clusterService, listener);
344344
}
345+
} else {
346+
listener.onResponse(deleteResponse.getResult() == DocWriteResponse.Result.DELETED);
345347
}
346-
listener.onFailure(e);
347-
}));
348+
},
349+
listener::onFailure
350+
));
348351
}
349352

350353
/**

0 commit comments

Comments
 (0)