added scheduler config logging on bootstrap (#1247)

Signed-off-by: Nir Rozenbaum <[email protected]>

Author: nirrozenbaum

cmd/epp/runner/runner.go

@@ -317,6 +317,9 @@ func (r *Runner) Run(ctx context.Context) error {
 		setupLog.Error(err, "failed to create scheduler")
 		return err
 	}
+
+	setupLog.Info("parsed config", "scheduler-config", r.schedulerConfig)
+
 	scheduler := scheduling.NewSchedulerWithConfig(r.schedulerConfig)
 
 	saturationDetector := saturationdetector.NewDetector(sdConfig, datastore, setupLog)
@@ -404,8 +407,6 @@ func (r *Runner) parsePluginsConfiguration(ctx context.Context) error {
 		return fmt.Errorf("failed to load the configuration - %w", err)
 	}
 
-	setupLog.Info("Configuration file loaded", "config", config)
-
 	r.schedulerConfig, err = loader.LoadSchedulerConfig(config.SchedulingProfiles, handle)
 	if err != nil {
 		return fmt.Errorf("failed to create Scheduler configuration - %w", err)

pkg/epp/scheduling/framework/scheduler_profile.go

@@ -19,6 +19,7 @@ package framework
 import (
 	"context"
 	"fmt"
+	"strings"
 	"time"
 
 	"sigs.k8s.io/controller-runtime/pkg/log"
@@ -105,6 +106,28 @@ func (p *SchedulerProfile) AddPlugins(pluginObjects ...plugins.Plugin) error {
 	return nil
 }
 
+func (p *SchedulerProfile) String() string {
+	filterNames := make([]string, len(p.filters))
+	for i, filter := range p.filters {
+		filterNames[i] = filter.TypedName().String()
+	}
+	scorerNames := make([]string, len(p.scorers))
+	for i, scorer := range p.scorers {
+		scorerNames[i] = fmt.Sprintf("%s: %d", scorer.TypedName(), scorer.Weight())
+	}
+	postCyclePluginNames := make([]string, len(p.postCyclePlugins))
+	for i, postCyclePlugin := range p.postCyclePlugins {
+		postCyclePluginNames[i] = postCyclePlugin.TypedName().String()
+	}
+	return fmt.Sprintf(
+		"{Filters: [%s], Scorers: [%s], Picker: %s, PostCyclePlugins: [%s]}",
+		strings.Join(filterNames, ", "),
+		strings.Join(scorerNames, ", "),
+		p.picker.TypedName(),
+		strings.Join(postCyclePluginNames, ", "),
+	)
+}
+
 // RunCycle runs a SchedulerProfile cycle. In other words, it invokes all the SchedulerProfile plugins in this
 // order - Filters, Scorers, Picker, PostCyclePlugins. After completing all, it returns the result.
 func (p *SchedulerProfile) Run(ctx context.Context, request *types.LLMRequest, cycleState *types.CycleState, candidatePods []types.Pod) (*types.ProfileRunResult, error) {

pkg/epp/scheduling/scheduler_config.go

@@ -17,6 +17,8 @@ limitations under the License.
 package scheduling
 
 import (
+	"fmt"
+
 	"sigs.k8s.io/gateway-api-inference-extension/pkg/epp/scheduling/framework"
 )
 
@@ -33,3 +35,11 @@ type SchedulerConfig struct {
 	profileHandler framework.ProfileHandler
 	profiles       map[string]*framework.SchedulerProfile
 }
+
+func (c *SchedulerConfig) String() string {
+	return fmt.Sprintf(
+		"{ProfileHandler: %s, Profiles: %v}",
+		c.profileHandler.TypedName(),
+		c.profiles,
+	)
+}