From e4615892cfc9d4a0625f91b35f53fd183a4f8509 Mon Sep 17 00:00:00 2001 From: satti-hari-krishna-reddy Date: Wed, 22 May 2024 20:53:27 +0530 Subject: [PATCH] removing a log message that is not needed --- functions/onprem/orborus/orborus.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go index aef3e620..626f415c 100755 --- a/functions/onprem/orborus/orborus.go +++ b/functions/onprem/orborus/orborus.go @@ -2091,9 +2091,7 @@ func handlePipeline(incRequest shuffle.ExecutionRequest) error { if err != nil { log.Printf("[ERROR] Failed Deleting Pipeline %s", err) return err - } else { - log.Printf("[INFO] successfully deleted the Pipeline: %s", pipelineId) - } + } } else if incRequest.Type == "PIPELINE_STOP" { log.Printf("[INFO] Should stop the pipeline %#v", identifier) pipelineId, err := searchPipeline(identifier) @@ -2301,7 +2299,7 @@ func createPipeline(command, identifier string) (string, error) { if err != nil { if strings.Contains(fmt.Sprintf("%s", err), "no existing pipeline found") { - log.Printf("[INFO] No existing pipeline found with name: %s. Creating a new one!", identifier) + log.Printf("[INFO] No existing pipeline found with id: %s. Creating a new one!", identifier) } else { log.Printf("[ERROR] Failed to search for existing pipeline but continuing anyway : %s", err) } @@ -2327,7 +2325,6 @@ func createPipeline(command, identifier string) (string, error) { command = command[:startIndex] + baseUrl + command[endIndex:] } } - requestBody := map[string]interface{}{ "definition": command, "name": identifier,