This is an automated email from the ASF dual-hosted git repository.
ccondit pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/yunikorn-core.git
The following commit(s) were added to refs/heads/master by this push:
new ebb8b1c5 [YUNIKORN-2901] Ensure queuees are created with proper queue
path (#997)
ebb8b1c5 is described below
commit ebb8b1c5fff7b7cf7f59b96d33d709679d9a041c
Author: Hengzhe <[email protected]>
AuthorDate: Wed Nov 20 18:46:34 2024 -0600
[YUNIKORN-2901] Ensure queuees are created with proper queue path (#997)
Closes: #997
Signed-off-by: Craig Condit <[email protected]>
---
pkg/scheduler/objects/queue.go | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/pkg/scheduler/objects/queue.go b/pkg/scheduler/objects/queue.go
index 5b62ca5c..11426387 100644
--- a/pkg/scheduler/objects/queue.go
+++ b/pkg/scheduler/objects/queue.go
@@ -119,6 +119,9 @@ func NewConfiguredQueue(conf configs.QueueConfig, parent
*Queue) (*Queue, error)
sq := newBlankQueue()
sq.Name = strings.ToLower(conf.Name)
sq.QueuePath = strings.ToLower(conf.Name)
+ if parent != nil {
+ sq.QueuePath = parent.QueuePath + configs.DOT + sq.Name
+ }
sq.parent = parent
sq.isManaged = true
sq.maxRunningApps = conf.MaxApplications
@@ -134,7 +137,6 @@ func NewConfiguredQueue(conf configs.QueueConfig, parent
*Queue) (*Queue, error)
// pull the properties from the parent that should be set on
the child
sq.mergeProperties(parent.getProperties(), conf.Properties)
sq.UpdateQueueProperties()
- sq.QueuePath = parent.QueuePath + configs.DOT + sq.Name
err := parent.addChildQueue(sq)
if err != nil {
return nil, errors.Join(errors.New("configured queue
creation failed: "), err)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
