Skip to content

Commit 9987b07

Browse files
committed
Cleanup workflow ExecutionReport upon allocation
1 parent 8b45944 commit 9987b07

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

internal/api/workflow.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,8 @@ func ResumeWorkflow(e echo.Context) error {
171171
req.Async = clientReq.Async
172172
req.Resuming = true
173173
req.Id = clientReq.ReqId
174+
req.ExecReport.ResponseTime = 0.0
175+
req.ExecReport.Result = map[string]interface{}{}
174176
req.ExecReport.Reports = map[string]*function.ExecutionReport{}
175177

176178
if clientReq.Plan.ToExecute != nil {
@@ -214,6 +216,8 @@ func InvokeWorkflow(e echo.Context) error {
214216
req.Plan = nil
215217
req.Resuming = false
216218
req.Id = fmt.Sprintf("%v-%s%d", wflow.Name, node.LocalNode.String()[len(node.LocalNode.String())-5:], req.Arrival.Nanosecond())
219+
req.ExecReport.ResponseTime = 0.0
220+
req.ExecReport.Result = map[string]interface{}{}
217221
req.ExecReport.Reports = map[string]*function.ExecutionReport{}
218222

219223
return handleWorkflowInvocation(e, req)

0 commit comments

Comments
 (0)