TO REMOVE: add debug info

Author: matteonardelli

internal/container/container.go

@@ -5,12 +5,13 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"fmt"
-	"github.com/serverledge-faas/serverledge/internal/function"
 	"io"
 	"log"
 	"net/http"
 	"time"
 
+	"github.com/serverledge-faas/serverledge/internal/function"
+
 	"github.com/serverledge-faas/serverledge/internal/executor"
 )
 
@@ -91,8 +92,10 @@ func Execute(contID ContainerID, req *executor.InvocationRequest) (*executor.Inv
 
 	postBody, _ := json.Marshal(req)
 	postBodyB := bytes.NewBuffer(postBody) // this buffer will be erased after send
+	fmt.Printf(">>> Before send POST request with retries, with body %v\n", req)
 	resp, waitDuration, err := sendPostRequestWithRetries(fmt.Sprintf("http://%s:%d/invoke", ipAddr,
 		executor.DEFAULT_EXECUTOR_PORT), postBodyB)
+	fmt.Printf(">>> err? %v\n", err)
 	if err != nil {
 		if resp != nil {
 			buffer, err2 := io.ReadAll(resp.Body)
@@ -104,6 +107,7 @@ func Execute(contID ContainerID, req *executor.InvocationRequest) (*executor.Inv
 		return nil, waitDuration, fmt.Errorf("request to executor failed: %v", err)
 	}
 
+	fmt.Printf(">>> resp.StatusCode? %v\n", resp.StatusCode)
 	if resp.StatusCode != 200 {
 		buffer, err2 := io.ReadAll(resp.Body)
 		if err2 != nil {
@@ -122,6 +126,9 @@ func Execute(contID ContainerID, req *executor.InvocationRequest) (*executor.Inv
 	response := &executor.InvocationResult{}
 
 	err = d.Decode(response)
+	fmt.Printf(">>> resp.Body? %v\n", resp.Body)
+	fmt.Printf(">>> decoded response? %v\n", response)
+
 	if err != nil {
 		return nil, waitDuration, fmt.Errorf("Parsing executor response failed: %v", err)
 	}

internal/container/docker.go

@@ -45,6 +45,8 @@ func (cf *DockerFactory) Create(image string, opts *ContainerOptions) (Container
 		contResources.CPUQuota = (int64)(50000.0 * opts.CPUQuota)
 	}
 
+	fmt.Printf("+++ creating container: %v; %v\n", image, opts)
+
 	resp, err := cf.cli.ContainerCreate(cf.ctx, &container.Config{
 		Image: image,
 		Cmd:   opts.Cmd,

internal/scheduling/execution.go

@@ -52,6 +52,8 @@ func Execute(cont *container.Container, r *scheduledRequest, isWarm bool) (funct
 		return function.ExecutionReport{}, fmt.Errorf("[%s] Execution failed on container %v: %v ", r, cont.ID, err)
 	}
 
+	fmt.Printf("Response: %v\n", response)
+
 	if !response.Success {
 		// notify scheduler
 		completions <- &completionNotification{fun: r.Fun, cont: cont, executionReport: nil}

internal/workflow/workflow.go

@@ -490,6 +490,8 @@ func (wflow *Workflow) Invoke(r *Request) error {
 			} else {
 				var found bool
 				previousTasks := wflow.GetPreviousTasks(taskToExecute)
+				fmt.Printf("+++ Computing inputs for task %v, {data-> %v}\n", taskToExecute, r.Params)
+
 				for _, previousTask := range previousTasks {
 					if progress.Status[previousTask] == Skipped {
 						continue
@@ -500,6 +502,8 @@ func (wflow *Workflow) Invoke(r *Request) error {
 					}
 
 					input, found = dataMap[previousTask]
+					fmt.Printf("+++ +++ dataMap[%v]: ({%v}, %v)\n", previousTask, input, found)
+
 					if !found {
 						log.Printf("Input not found in dataMap for previousTask %s", previousTask)
 						input, err = RetrievePartialData(requestId, previousTask)
@@ -516,7 +520,7 @@ func (wflow *Workflow) Invoke(r *Request) error {
 			}
 			output, err := wflow.ExecuteTask(r, taskToExecute, input, progress)
 			if err != nil {
-				return fmt.Errorf("failed wflow execution: %v", err)
+				return fmt.Errorf("failed wflow execution: %v (while running task: %v)", err, taskToExecute)
 			}
 
 			dataMap[taskToExecute] = output