mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
fn: add missing dequeue in agent Submit (#1220)
This commit is contained in:
@@ -322,6 +322,7 @@ func (a *agent) handleCallEnd(ctx context.Context, call *call, slot Slot, err er
|
|||||||
statsComplete(ctx)
|
statsComplete(ctx)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
statsDequeue(ctx)
|
||||||
if err == CapacityFull || err == context.DeadlineExceeded {
|
if err == CapacityFull || err == context.DeadlineExceeded {
|
||||||
statsTooBusy(ctx)
|
statsTooBusy(ctx)
|
||||||
return models.ErrCallTimeoutServerBusy
|
return models.ErrCallTimeoutServerBusy
|
||||||
|
|||||||
Reference in New Issue
Block a user