If there are running jobs in the Volcano queue, is it permissible to directly delete the queue?

[hzp01]

volcanoClient.queues().withName(queueName).delete();

[rohanKanojia]

Sorry, but could you please elaborate your question?

[hzp01]

The following is the logical check I implemented in my code.

        NamespacedVolcanoClient volcanoClient = VolcanoClient.getVolcanoClient();
        GenericKubernetesResourceList list = VolcanoJobQuery.volcanoJobQueryList();
        Boolean haveNotEndJobInQueue = false;
        List<String> jobEndStatus = Arrays.asList("succeeded", "failed", "unknown", "completed", "failed");
        if (list != null && !list.getItems().isEmpty()) {
            haveNotEndJobInQueue = list.getItems().stream().filter(item -> {
                try {
                    return queueName.equals(((LinkedHashMap) item.get("spec")).get("queue").toString());
                } catch (Exception e) {
                    return false;
                }
            }).anyMatch(item -> {
                try {
                    return jobEndStatus.contains(((LinkedHashMap) ((LinkedHashMap) item.get("status")).get("state")).get("phase").toString().toLowerCase());
                } catch (Exception e) {
                    System.out.println(e);
                    return false;
                }
            });
        }
        if(!haveNotEndJobInQueue){
            volcanoClient.queues().withName(queueName).delete();
        }
        volcanoClient.close();

[rohanKanojia]

I see. What problem are you facing with this code?

[hzp01]

The code is lengthy, and I'm wondering if there is already an API that implements this functionality, but I'm not sure.

[rohanKanojia]

I'm not aware of any API in fabric8 k8s client that implements this. You would need to check with volcano community on how they handle this Queue delete precondition. I checked their Queue controller but couldn't find any implemented finalizer. Not 100% sure maybe this can be added as a finalizer in Volcano?

[hzp01]

Okay, thank you.