Fix for cases without default localqueue

Ygnas · Ygnas · commit 0be3b98e24fd · 2024-05-20T11:05:42.000+01:00
diff --git a/src/codeflare_sdk/cluster/cluster.py b/src/codeflare_sdk/cluster/cluster.py
@@ -541,6 +541,9 @@ def from_k8_cluster_object(
             mcad=mcad,
             write_to_file=write_to_file,
             verify_tls=verify_tls,
+            local_queue=rc["metadata"]
+            .get("labels", dict())
+            .get("kueue.x-k8s.io/queue-name", None),
         )
         return Cluster(cluster_config)
 

Original file line number	Diff line number	Diff line change
`@@ -541,6 +541,9 @@ def from_k8_cluster_object(`
`541`	`541`	`mcad=mcad,`
`542`	`542`	`write_to_file=write_to_file,`
`543`	`543`	`verify_tls=verify_tls,`
	`544`	`+ local_queue=rc["metadata"]`
	`545`	`+ .get("labels", dict())`
	`546`	`+ .get("kueue.x-k8s.io/queue-name", None),`
`544`	`547`	`)`
`545`	`548`	`return Cluster(cluster_config)`
`546`	`549`