public Mono deleteJob()

in src/main/java/com/epam/aidial/kubernetes/KubernetesClient.java [200:222]

22 lines of code
2 McCabe index (conditional complexity)


    public Mono<Boolean> deleteJob(String namespace, String name) {
        return handleMissing(Mono.create(sink -> {
            BatchV1Api batchV1Api = new BatchV1Api(apiClient);
            log.info("Deleting job {}", name);
            try {
                batchV1Api.deleteNamespacedJob(name, namespace)
                        .executeAsync(new NoProgressApiCallback<>() {
                            @Override
                            public void onFailure(ApiException e, int i, Map<String, List<String>> map) {
                                sink.error(e);
                            }

                            @Override
                            public void onSuccess(V1Status state, int i, Map<String, List<String>> map) {
                                log.info("Job {} has been deleted", name);
                                sink.success();
                            }
                        });
            } catch (ApiException e) {
                sink.error(e);
            }
        }));
    }