From 152ce9f02fc1a49773317ace6f70c4b953531715 Mon Sep 17 00:00:00 2001
From: Aditya <60684641+0x0elliot@users.noreply.github.com>
Date: Tue, 1 Oct 2024 18:47:18 +0530
Subject: [PATCH] fix: making REGISTRY_URL get pushed to k8s

---
 functions/onprem/orborus/orborus.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go
index dee7c159..174fe2c6 100755
--- a/functions/onprem/orborus/orborus.go
+++ b/functions/onprem/orborus/orborus.go
@@ -961,6 +961,10 @@ func deployK8sWorker(image string, identifier string, env []string) error {
 		env = append(env, fmt.Sprintf("KUBERNETES_SERVICE_PORT=%s", os.Getenv("KUBERNETES_SERVICE_PORT")))
 	}
 
+	if len(os.Getenv("REGISTRY_URL")) > 0 {
+		env = append(env, fmt.Sprintf("REGISTRY_URL=%s", os.Getenv("REGISTRY_URL")))
+	}
+
 	clientset, _, err := shuffle.GetKubernetesClient()
 	if err != nil {
 		log.Printf("[ERROR] Error getting kubernetes client:", err)