[YUNIKORN-2907] Queue config processing log spew

pkg/scheduler/objects/queue.go

@@ -113,9 +113,29 @@ func newBlankQueue() *Queue {
 	}
 }
 
-// NewConfiguredQueue creates a new queue from scratch based on the configuration
+// NewConfiguredQueue creates a new queue from scratch based on the configuration and logs at info level
 // lock free as it cannot be referenced yet
 func NewConfiguredQueue(conf configs.QueueConfig, parent *Queue) (*Queue, error) {
+	queue, err := newConfiguredQueueInternal(conf, parent)
+	if queue != nil {
+		log.Log(log.SchedQueue).Info("configured queue added to scheduler",
+			zap.String("queueName", queue.QueuePath))
+	}
+	return queue, err
+}
+
+// NewConfiguredShadowQueue creates a new queue from scratch based on the configuration and logs at debug level
+// lock free as it cannot be referenced yet
+func NewConfiguredShadowQueue(conf configs.QueueConfig, parent *Queue) (*Queue, error) {
+	queue, err := newConfiguredQueueInternal(conf, parent)
+	if queue != nil {
+		log.Log(log.SchedQueue).Debug("shadow queue created",
+			zap.String("queueName", queue.QueuePath))
+	}
+	return queue, err
+}
+
+func newConfiguredQueueInternal(conf configs.QueueConfig, parent *Queue) (*Queue, error) {
 	sq := newBlankQueue()
 	sq.Name = strings.ToLower(conf.Name)
 	sq.QueuePath = strings.ToLower(conf.Name)
@@ -145,8 +165,6 @@ func NewConfiguredQueue(conf configs.QueueConfig, parent *Queue) (*Queue, error)
 		sq.UpdateQueueProperties()
 	}
 	sq.queueEvents = schedEvt.NewQueueEvents(events.GetEventSystem())
-	log.Log(log.SchedQueue).Info("configured queue added to scheduler",
-		zap.String("queueName", sq.QueuePath))
 	sq.queueEvents.SendNewQueueEvent(sq.QueuePath, sq.isManaged)
 
 	return sq, nil

pkg/scheduler/partition.go

@@ -224,7 +224,7 @@ func (pc *PartitionContext) updateQueues(config []configs.QueueConfig, parent *o
 		queue := pc.getQueueInternal(pathName)
 		var err error
 		if queue == nil {
-			queue, err = objects.NewConfiguredQueue(queueConfig, parent)
+			queue, err = objects.NewConfiguredShadowQueue(queueConfig, parent)
 		} else {
 			err = queue.ApplyConf(queueConfig)
 		}