fix(backend): Replaced hardcoded ServiceAccount with default config (#…

…11578)

Signed-off-by: Helber Belmiro <[email protected]>

backend/src/apiserver/resource/resource_manager_test.go

@@ -2347,6 +2347,40 @@ func TestCreateJob_ThroughWorkflowSpecV2(t *testing.T) {
 	assert.Equal(t, expectedJob.ToV1(), fetchedJob.ToV1(), "CreateJob stored invalid data in database")
 }
 
+func TestCreateJobDifferentDefaultServiceAccountName_ThroughWorkflowSpecV2(t *testing.T) {
+	originalDefaultServiceAccount := viper.Get(common.DefaultPipelineRunnerServiceAccountFlag)
+
+	viper.Set(common.DefaultPipelineRunnerServiceAccountFlag, "my-service-account")
+	defer viper.Set(common.DefaultPipelineRunnerServiceAccountFlag, originalDefaultServiceAccount)
+
+	store, manager, job := initWithJobV2(t)
+	defer store.Close()
+	expectedJob := &model.Job{
+		UUID:           "123e4567-e89b-12d3-a456-426655440000",
+		DisplayName:    "j1",
+		K8SName:        "job-",
+		Namespace:      "ns1",
+		ServiceAccount: "my-service-account",
+		Enabled:        true,
+		ExperimentId:   DefaultFakeUUID,
+		CreatedAtInSec: 2,
+		UpdatedAtInSec: 2,
+		Conditions:     "STATUS_UNSPECIFIED",
+		PipelineSpec: model.PipelineSpec{
+			PipelineSpecManifest: v2SpecHelloWorld,
+			RuntimeConfig: model.RuntimeConfig{
+				Parameters:   "{\"text\":\"world\"}",
+				PipelineRoot: "job-1-root",
+			},
+		},
+	}
+	expectedJob.PipelineSpec.PipelineName = job.PipelineSpec.PipelineName
+	require.Equal(t, expectedJob.ToV1(), job.ToV1())
+	fetchedJob, err := manager.GetJob(job.UUID)
+	require.Nil(t, err)
+	require.Equal(t, expectedJob.ToV1(), fetchedJob.ToV1(), "CreateJob stored invalid data in database")
+}
+
 func TestCreateJob_ThroughPipelineID(t *testing.T) {
 	store, manager, pipeline, _ := initWithPipeline(t)
 	defer store.Close()

backend/src/v2/compiler/argocompiler/argo.go

@@ -19,6 +19,7 @@ import (
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"github.com/kubeflow/pipelines/backend/src/apiserver/common"
 	"strings"
 
 	wfapi "github.com/argoproj/argo-workflows/v3/pkg/apis/workflow/v1alpha1"
@@ -115,7 +116,7 @@ func Compile(jobArg *pipelinespec.PipelineJob, kubernetesSpecArg *pipelinespec.S
 			Arguments: wfapi.Arguments{
 				Parameters: []wfapi.Parameter{},
 			},
-			ServiceAccountName: "pipeline-runner",
+			ServiceAccountName: common.GetStringConfigWithDefault(common.DefaultPipelineRunnerServiceAccountFlag, common.DefaultPipelineRunnerServiceAccount),
 			Entrypoint:         tmplEntrypoint,
 		},
 	}