getting worker image from registry

functions/final-specs/final-specs/shuffle-cm.yaml

@@ -55,6 +55,7 @@ data:
   IS_KUBERNETES: "true"
   REGISTRY_URL: "172.17.14.71:5000"
   #REGISTRY_AUTH: ""
+  SHUFFLE_KUBERNETES_WORKER: "dhavald055/shuffle-k8s:shuffle-worker-kubernetes"
 kind: ConfigMap
 metadata:
   creationTimestamp: null

functions/final-specs/final-specs/shuffle-orborus.yaml

@@ -52,6 +52,11 @@ spec:
                 configMapKeyRef:
                   key: REGISTRY_URL
                   name: env
+            - name: SHUFFLE_KUBERNETES_WORKER
+              valueFrom:
+                configMapKeyRef:
+                  key: SHUFFLE_KUBERNETES_WORKER
+                  name: env
 
           image: dhavald055/shuffle-k8s:shuffle-orborus-kubernetes
           #imagePullPolicy: Never

functions/onprem/orborus/orborus.go

@@ -589,7 +589,9 @@ func deployWorker(image string, identifier string, env []string, executionReques
 			env = append(env, fmt.Sprintf("IS_KUBERNETES=%s", os.Getenv("IS_KUBERNETES")))
 		}
 
-		image = "shuffle-worker:v1" //hard coded image name to test locally
+		image = os.Getenv("SHUFFLE_KUBERNETES_WORKER")
+		log.Printf("[DEBUG] using worker image:", image)
+		// image = "shuffle-worker:v1" //hard coded image name to test locally
 
 		envMap := make(map[string]string)
 		for _, envStr := range env {