in src/main/java/com/epam/grid/engine/provider/job/sge/SgeJobProvider.java [183:202]
public Listing<DeletedJobInfo> deleteJob(final DeleteJobFilter deleteJobFilter) {
final Map<Long, String> jobOwners = getJobOwners(deleteJobFilter);
if (jobOwners.isEmpty()) {
throw new GridEngineException(HttpStatus.NOT_FOUND,
String.format("No jobs found from the specified %s to remove!", deleteJobFilter));
}
final CommandResult result = simpleCmdExecutor.execute(makeQdelCommand(deleteJobFilter));
final List<Long> deletedJobIds = parseDeletedJobId(result.getStdOut());
if (result.getExitCode() != 0) {
if (deletedJobIds.isEmpty()) {
CommandsUtils.throwExecutionDetails(result, HttpStatus.NOT_FOUND);
} else {
log.warn(JOBS_DELETING_EXECUTION_RESULT + result);
}
}
return new Listing<>(deletedJobIds.stream()
.map(id -> new DeletedJobInfo(id, jobOwners.get(id)))
.collect(Collectors.toList()));
}