Skip to content

Commit 50dad17

Browse files
committed
Fix for cases without default local_queue
1 parent 179fd75 commit 50dad17

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/codeflare_sdk/cluster/cluster.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -512,6 +512,12 @@ def from_k8_cluster_object(
512512
else []
513513
)
514514

515+
local_queue = (
516+
rc["metadata"]["labels"]["kueue.x-k8s.io/queue-name"]
517+
if "kueue.x-k8s.io/queue-name" in rc["metadata"]["labels"]
518+
else ""
519+
)
520+
515521
cluster_config = ClusterConfiguration(
516522
name=rc["metadata"]["name"],
517523
namespace=rc["metadata"]["namespace"],
@@ -541,6 +547,7 @@ def from_k8_cluster_object(
541547
mcad=mcad,
542548
write_to_file=write_to_file,
543549
verify_tls=verify_tls,
550+
local_queue=local_queue,
544551
)
545552
return Cluster(cluster_config)
546553

0 commit comments

Comments
 (0)