Allows to set verbosity on runner

cmd/kperf/commands/runnergroup/run.go

@@ -46,6 +46,11 @@ var runCommand = cli.Command{
 			Name:  "affinity",
 			Usage: "Deploy server to the node with a specific labels (FORMAT: KEY=VALUE[,VALUE])",
 		},
+		cli.IntFlag{
+			Name:  "runner-verbosity",
+			Usage: "The verbosity level of runners",
+			Value: 2,
+		},
 	},
 	Action: func(cliCtx *cli.Context) error {
 		imgRef := cliCtx.String("runner-image")
@@ -76,6 +81,7 @@ var runCommand = cli.Command{
 			kubeCfgPath,
 			imgRef,
 			specs[0],
+			cliCtx.Int("runner-verbosity"),
 			runner.WithRunCmdServerNodeSelectorsOpt(affinityLabels),
 			runner.WithRunCmdRunnerGroupFlowControl(priorityLevel, matchingPrecedence),
 		)

cmd/kperf/commands/runnergroup/server.go

@@ -52,6 +52,11 @@ var serverCommand = cli.Command{
 			Usage:    "The runner result should be stored in that path",
 			Required: true,
 		},
+		cli.IntFlag{
+			Name:  "runner-verbosity",
+			Usage: "The verbosity level of runners",
+			Value: 2,
+		},
 	},
 	Hidden: true,
 	Action: func(cliCtx *cli.Context) error {
@@ -90,6 +95,7 @@ func buildRunnerGroupHandlers(cliCtx *cli.Context, serverName string) ([]*runner
 	specURIs := cliCtx.StringSlice("runnergroup")
 	imgRef := cliCtx.String("runner-image")
 	namespace := cliCtx.String("namespace")
+	runnerVerbosity := cliCtx.Int("runner-verbosity")
 
 	ownerRef := ""
 	if cliCtx.IsSet("runner-owner") {
@@ -117,7 +123,7 @@ func buildRunnerGroupHandlers(cliCtx *cli.Context, serverName string) ([]*runner
 		}
 
 		groupName := fmt.Sprintf("%s-%d", serverName, idx)
-		g, err := runnergroup.NewHandler(clientset, namespace, groupName, spec, imgRef)
+		g, err := runnergroup.NewHandler(clientset, namespace, groupName, spec, imgRef, runnerVerbosity)
 		if err != nil {
 			return nil, err
 		}

manifests/runnergroup/server/templates/pod.yaml

@@ -35,6 +35,8 @@ spec:
     - v1:Pod:$(POD_NAME):$(POD_UID)
     - --runner-sa
     - {{ .Values.name }}
+    - --runner-verbosity
+    - {{ .Values.runnerVerbosity }}
     - --address
     - $(POD_IP):8080
     - --address

manifests/runnergroup/server/values.yaml

@@ -2,6 +2,7 @@ name: ""
 image: ""
 # TODO(weifu): need https://github.com/Azure/kperf/issues/25 to support list
 runnerGroupSpec: ""
+runnerVerbosity: "2"
 nodeSelectors: {}
 flowcontrol:
   priorityLevelConfiguration: workload-low

runner/group/handler.go

@@ -8,6 +8,7 @@ import (
 	"errors"
 	"fmt"
 	"reflect"
+	"strconv"
 	"strings"
 	"time"
 
@@ -45,6 +46,8 @@ type Handler struct {
 	imageRef string
 
 	clientset kubernetes.Interface
+
+	runnerVerbosity int
 }
 
 // NewHandler returns new instance of Handler.
@@ -53,19 +56,21 @@ func NewHandler(
 	namespace, name string,
 	spec *types.RunnerGroupSpec,
 	imageRef string,
+	runnerVerbosity int,
 ) (*Handler, error) {
 	ownRef, err := buildOwnerReference(spec.OwnerReference)
 	if err != nil {
 		return nil, err
 	}
 
 	return &Handler{
-		name:      name,
-		namespace: namespace,
-		spec:      spec,
-		ownerRef:  ownRef,
-		imageRef:  imageRef,
-		clientset: clientset,
+		name:            name,
+		namespace:       namespace,
+		spec:            spec,
+		ownerRef:        ownRef,
+		imageRef:        imageRef,
+		clientset:       clientset,
+		runnerVerbosity: runnerVerbosity,
 	}, nil
 }
 
@@ -404,6 +409,10 @@ func (h *Handler) buildBatchJobObject(uploadURL string) *batchv1.Job {
 						Name:  "TARGET_URL",
 						Value: uploadURL,
 					},
+					{
+						Name:  "RUNNER_VERBOSITY",
+						Value: strconv.Itoa(h.runnerVerbosity),
+					},
 				},
 				VolumeMounts: []corev1.VolumeMount{
 					{

runner/runnergroup_run.go

@@ -36,6 +36,7 @@ func CreateRunnerGroupServer(ctx context.Context,
 	kubeconfigPath string,
 	runnerImage string,
 	rgSpec *types.RunnerGroupSpec,
+	runnerVerbosity int,
 	opts ...RunCmdOpt,
 ) error {
 	specInStr, err := tweakAndMarshalSpec(rgSpec)
@@ -78,6 +79,8 @@ func CreateRunnerGroupServer(ctx context.Context,
 			"name="+runnerGroupServerReleaseName,
 			"image="+runnerImage,
 			"runnerGroupSpec="+specInStr,
+			// runnerVerbosity needs to be surrounded by quotes, so that YAML parse it as a string.
+			fmt.Sprintf("runnerVerbosity=\"%d\"", runnerVerbosity),
 		),
 		appiler,
 	)

scripts/run_runner.sh

@@ -7,8 +7,8 @@ set -euo pipefail
 
 result_file=/data/${POD_NAMESPACE}-${POD_NAME}-${POD_UID}.json
 
-/kperf -v=2 runner run --config=/config/load_profile.yaml \
-		--user-agent=${POD_NAME} \
+/kperf -v=${RUNNER_VERBOSITY} runner run --config=/config/load_profile.yaml \
+    --user-agent=${POD_NAME} \
     --result=${result_file} \
     --raw-data