Adds workflow scheduling time in report

Author: grussorusso

internal/api/workflow.go

@@ -7,7 +7,6 @@ import (
 	"fmt"
 	"io"
 	"log"
-	"maps"
 	"net/http"
 	"time"
 
@@ -218,6 +217,7 @@ func InvokeWorkflow(e echo.Context) error {
 	req.Resuming = false
 	req.Id = fmt.Sprintf("%v-%s%d", wflow.Name, node.LocalNode.String()[len(node.LocalNode.String())-5:], req.Arrival.Nanosecond())
 	req.ExecReport.ResponseTime = 0.0
+	req.ExecReport.SchedulingTime = 0.0
 	req.ExecReport.Result = nil // NOTE: this should be nil until workflow completion
 	req.ExecReport.Reports = map[string]*function.ExecutionReport{}
 
@@ -238,13 +238,13 @@ func handleWorkflowInvocation(e echo.Context, req *workflow.Request) error {
 				return
 			}
 
-			log.Printf("Invocation succeeded. Publishing: %v", req.ExecReport)
 			req.ExecReport.ResponseTime = time.Now().Sub(req.Arrival).Seconds()
 			workflow.PublishAsyncInvocationResponse(req.Id, workflow.InvocationResponse{
-				Success:      true,
-				Result:       req.ExecReport.Result,
-				Reports:      req.ExecReport.Reports,
-				ResponseTime: req.ExecReport.ResponseTime,
+				Success:        true,
+				Result:         req.ExecReport.Result,
+				Reports:        req.ExecReport.Reports,
+				ResponseTime:   req.ExecReport.ResponseTime,
+				SchedulingTime: req.ExecReport.SchedulingTime,
 			})
 		}()
 
@@ -264,14 +264,12 @@ func handleWorkflowInvocation(e echo.Context, req *workflow.Request) error {
 	} else {
 		req.ExecReport.ResponseTime = time.Now().Sub(req.Arrival).Seconds()
 
-		// TODO
-		log.Printf("Invocation succeeded. Returning %d reports for keys: %v", len(req.ExecReport.Reports), maps.Keys(req.ExecReport.Reports))
-
 		return e.JSON(http.StatusOK, workflow.InvocationResponse{
-			Success:      true,
-			Result:       req.ExecReport.Result,
-			Reports:      req.ExecReport.Reports,
-			ResponseTime: req.ExecReport.ResponseTime,
+			Success:        true,
+			Result:         req.ExecReport.Result,
+			Reports:        req.ExecReport.Reports,
+			ResponseTime:   req.ExecReport.ResponseTime,
+			SchedulingTime: req.ExecReport.SchedulingTime,
 		})
 	}
 }

internal/workflow/report.go

@@ -10,9 +10,10 @@ func CreateExecutionReportId(task Task) string {
 }
 
 type ExecutionReport struct {
-	Result       map[string]interface{}
-	Reports      map[string]*function.ExecutionReport
-	ResponseTime float64 // time waited by the user to get the output of the entire workflow
+	Result         map[string]interface{}
+	Reports        map[string]*function.ExecutionReport
+	ResponseTime   float64 // time waited by the user to get the output of the entire workflow
+	SchedulingTime float64
 }
 
 func (cer *ExecutionReport) String() string {

internal/workflow/request.go

@@ -42,10 +42,11 @@ func NewRequest(reqId string, workflow *Workflow, params map[string]interface{},
 }
 
 type InvocationResponse struct {
-	Success      bool
-	Result       map[string]interface{}
-	Reports      map[string]*function.ExecutionReport
-	ResponseTime float64 // time waited by the user to get the output of the entire workflow (in seconds)
+	Success        bool
+	Result         map[string]interface{}
+	Reports        map[string]*function.ExecutionReport
+	ResponseTime   float64 // time waited by the user to get the output of the entire workflow (in seconds)
+	SchedulingTime float64
 }
 
 type AsyncInvocationResponse struct {

internal/workflow/workflow.go

@@ -441,7 +441,10 @@ func (wflow *Workflow) Invoke(r *Request) error {
 	}
 
 	for len(progress.ReadyToExecute) > 0 {
+		t0 := time.Now()
 		decision, err := offloadingPolicy.Evaluate(r, progress)
+		policyTime := time.Since(t0).Seconds()
+		r.ExecReport.SchedulingTime += policyTime
 
 		if err != nil {
 			return fmt.Errorf("an error occurred in policy evaluation: %v", err)
@@ -616,6 +619,8 @@ func offload(r *Request, policyDecision *OffloadingDecision) error {
 		r.ExecReport.Reports[k] = v
 	}
 
+	r.ExecReport.SchedulingTime += response.SchedulingTime
+
 	if response.Result == nil {
 		// workflow execution is not complete after offloading
 		r.ExecReport.Result = nil