Use profile from environment variable CLUSTER_PROFILE

Author: guillaumerose

hack/cluster-version-util/task_graph.go

@@ -30,7 +30,7 @@ func newTaskGraphCmd() *cobra.Command {
 
 func runTaskGraphCmd(cmd *cobra.Command, args []string) error {
 	manifestDir := args[0]
-	release, err := payload.LoadUpdate(manifestDir, "", "")
+	release, err := payload.LoadUpdate(manifestDir, "", "", payload.DefaultClusterProfile)
 	if err != nil {
 		return err
 	}

pkg/cvo/cvo.go

@@ -148,6 +148,8 @@ type Operator struct {
 	// exclude is an optional identifier used to exclude certain manifests
 	// via annotation
 	exclude string
+
+	clusterProfile string
 }
 
 // New returns a new cluster version operator.
@@ -166,6 +168,7 @@ func New(
 	client clientset.Interface,
 	kubeClient kubernetes.Interface,
 	exclude string,
+	clusterProfile string,
 ) *Operator {
 	eventBroadcaster := record.NewBroadcaster()
 	eventBroadcaster.StartLogging(klog.Infof)
@@ -194,7 +197,8 @@ func New(
 		availableUpdatesQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "availableupdates"),
 		upgradeableQueue:      workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "upgradeable"),
 
-		exclude: exclude,
+		exclude:        exclude,
+		clusterProfile: clusterProfile,
 	}
 
 	cvInformer.Informer().AddEventHandler(optr.eventHandler())
@@ -219,7 +223,7 @@ func New(
 // controller that loads and applies content to the cluster. It returns an error if the payload appears to
 // be in error rather than continuing.
 func (optr *Operator) InitializeFromPayload(restConfig *rest.Config, burstRestConfig *rest.Config) error {
-	update, err := payload.LoadUpdate(optr.defaultPayloadDir(), optr.release.Image, optr.exclude)
+	update, err := payload.LoadUpdate(optr.defaultPayloadDir(), optr.release.Image, optr.exclude, optr.clusterProfile)
 	if err != nil {
 		return fmt.Errorf("the local release contents are invalid - no current version can be determined from disk: %v", err)
 	}
@@ -261,6 +265,7 @@ func (optr *Operator) InitializeFromPayload(restConfig *rest.Config, burstRestCo
 		},
 		optr.exclude,
 		optr.eventRecorder,
+		optr.clusterProfile,
 	)
 
 	return nil