ArtifactRepositoryRef ConfigMap is now taken from the workflow namespace

Previously it was using the workflow controller's namespace.

workflow/controller/config_controller.go

@@ -156,11 +156,16 @@ func ReadConfigMapValue(clientset kubernetes.Interface, namespace string, name s
 	return value, nil
 }
 
-func getArtifactRepositoryRef(wfc *WorkflowController, configMapName string, key string) (*config.ArtifactRepository, error) {
-	configStr, err := ReadConfigMapValue(wfc.kubeclientset, wfc.namespace, configMapName, key)
+func getArtifactRepositoryRef(wfc *WorkflowController, configMapName string, key string, namespace string) (*config.ArtifactRepository, error) {
+	// Getting the ConfigMap from the workflow's namespace
+	configStr, err := ReadConfigMapValue(wfc.kubeclientset, namespace, configMapName, key)
 	if err != nil {
-		return nil, err
-	}
+		// Falling back to getting the ConfigMap from the controller's namespace
+		configStr, err = ReadConfigMapValue(wfc.kubeclientset, wfc.namespace, configMapName, key)
+		if err != nil {
+			return nil, err
+		}
+    }
 	var config config.ArtifactRepository
 	err = yaml.Unmarshal([]byte(configStr), &config)
 	if err != nil {

workflow/controller/operator.go

@@ -192,7 +192,7 @@ func (woc *wfOperationCtx) operate() {
 
 	if woc.wf.Spec.ArtifactRepositoryRef != nil {
 		repoReference := woc.wf.Spec.ArtifactRepositoryRef
-		repo, err := getArtifactRepositoryRef(woc.controller, repoReference.ConfigMap, repoReference.Key)
+		repo, err := getArtifactRepositoryRef(woc.controller, repoReference.ConfigMap, repoReference.Key, woc.wf.ObjectMeta.Namespace)
 		if err == nil {
 			woc.artifactRepository = repo
 		} else {