Skip to content

Commit

Permalink
removing a log message that is not needed
Browse files Browse the repository at this point in the history
  • Loading branch information
satti-hari-krishna-reddy committed May 22, 2024
1 parent 7d110bc commit e4f09ec
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions functions/onprem/orborus/orborus.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -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)
}
Expand All @@ -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,
Expand Down

0 comments on commit e4f09ec

Please sign in to comment.