From 2efa051f68d0d3c62bb941b8292e3429c379f5a5 Mon Sep 17 00:00:00 2001
From: satti-hari-krishna-reddy <hari.100.hks@outlook.com>
Date: Tue, 21 May 2024 15:31:21 +0530
Subject: [PATCH] added a conditional check to not replace the base url if it
 shuffler.io

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

diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go
index dc9e554c..cdface09 100755
--- a/functions/onprem/orborus/orborus.go
+++ b/functions/onprem/orborus/orborus.go
@@ -2286,8 +2286,9 @@ func createPipeline(command, identifier string) (string, error) {
 		log.Printf("[INFO] an existing pipeline found with ID: %s. it will be deleted", pipelineId)
 		toBeDeleted = true
 	}
+    if strings.Contains(command, "shuffler.io") {
 
-	if strings.Contains(command, "kafka") {
+	} else {
 		var scheme string
 		if strings.Contains(command, "http://") {
 			scheme = "http://"