Minor

Author: grussorusso

internal/lb/common.go

@@ -14,23 +14,23 @@ func getTargetStatus(targetUrl string) (registration.StatusInformation, error) {
 	path, _ := url.JoinPath(targetUrl, "/status")
 	resp, err := http.Get(path)
 	if err != nil {
-		log.Fatalf("Invocation to get status failed: %v", err)
+		log.Printf("Invocation to get status failed: %v", err)
 		return registration.StatusInformation{}, err
 	}
 	defer resp.Body.Close()
 
 	// Read the response body
 	body, err := io.ReadAll(resp.Body)
 	if err != nil {
-		log.Fatalf("Error reading response body: %v", err)
+		log.Printf("Error reading response body: %v", err)
 		return registration.StatusInformation{}, err
 	}
 
 	// Check the status code
 	if resp.StatusCode == http.StatusOK {
 		var statusInfo registration.StatusInformation
 		if err := json.Unmarshal(body, &statusInfo); err != nil {
-			log.Fatalf("Error decoding JSON: %v", err)
+			log.Printf("Error decoding JSON: %v", err)
 			return registration.StatusInformation{}, errors.New("could not get status information")
 		}
 		return statusInfo, nil

internal/workflow/workflow.go

@@ -505,7 +505,6 @@ func (wflow *Workflow) Invoke(r *Request) error {
 
 					input, found = dataMap[previousTask]
 					if !found {
-						log.Printf("Input not found in dataMap for previousTask %s", previousTask)
 						input, err = RetrievePartialData(requestId, previousTask)
 						if err != nil {
 							return fmt.Errorf("Could not retrieve partial data: %v", err)