Add ConsoleURL to flyteadmin config and write it to CRD

Signed-off-by: Eduardo Apolinario <[email protected]>
flyteorg · Jun 6, 2024 · e5b6590 · e5b6590
1 parent d8ae70e
commit e5b6590
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/flyteadmin/pkg/runtime/application_config_provider.go b/flyteadmin/pkg/runtime/application_config_provider.go
@@ -33,6 +33,7 @@ var flyteAdminConfig = config.MustRegisterSection(flyteAdmin, &interfaces.Applic
 	MaxParallelism:              25,
 	K8SServiceAccount:           "",
 	UseOffloadedWorkflowClosure: false,
+	ConsoleUrl:                  "",
 })
 
 var schedulerConfig = config.MustRegisterSection(scheduler, &interfaces.SchedulerConfig{

diff --git a/flyteadmin/pkg/runtime/interfaces/application_configuration.go b/flyteadmin/pkg/runtime/interfaces/application_configuration.go
@@ -103,6 +103,9 @@ type ApplicationConfig struct {
 	Envs map[string]string `json:"envs,omitempty"`
 
 	FeatureGates FeatureGates `json:"featureGates" pflag:",Enable experimental features."`
+
+	// A URL pointing to the flyteconsole instance used to hit this flyteadmin instance.
+	ConsoleURL string `json:"consoleUrl,omitempty"`
 }
 
 func (a *ApplicationConfig) GetRoleNameKey() string {

diff --git a/flyteadmin/pkg/workflowengine/impl/k8s_executor.go b/flyteadmin/pkg/workflowengine/impl/k8s_executor.go
@@ -55,6 +55,10 @@ func (e K8sWorkflowExecutor) Execute(ctx context.Context, data interfaces.Execut
 		flyteWf.Tasks = nil
 	}
 
+	if e.config.ApplicationConfiguration().GetTopLevelConfig().ConsoleURL != "" {
+		flyteWf.ConsoleURL = e.config.ApplicationConfiguration().GetTopLevelConfig().ConsoleURL
+	}
+
 	executionTargetSpec := executioncluster.ExecutionTargetSpec{
 		Project:               data.ExecutionID.Project,
 		Domain:                data.ExecutionID.Domain,