We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 65e060e commit 2b0b97cCopy full SHA for 2b0b97c
1 file changed
internal/scheduling/scheduler.go
@@ -64,12 +64,12 @@ func Run(p Policy) {
64
go p.OnArrival(r)
65
case c = <-completions:
66
node.ReleaseContainer(c.contID, c.Fun)
67
- p.OnCompletion(r)
+ p.OnCompletion(c.scheduledRequest)
68
69
if metrics.Enabled {
70
- metrics.AddCompletedInvocation(r.Fun.Name)
71
- if r.ExecReport.SchedAction != SCHED_ACTION_OFFLOAD {
72
- metrics.AddFunctionDurationValue(r.Fun.Name, r.ExecReport.Duration)
+ metrics.AddCompletedInvocation(c.Fun.Name)
+ if c.ExecReport.SchedAction != SCHED_ACTION_OFFLOAD {
+ metrics.AddFunctionDurationValue(c.Fun.Name, c.ExecReport.Duration)
73
}
74
75
0 commit comments