-
Notifications
You must be signed in to change notification settings - Fork 365
feat: dequeue worker request on timeout #1540
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Not sure, why the builds are failing. |
Seems like this command fails since it tries to update go to |
It would be nice to automatically use the latest patch version. |
max_wait_time
@AlliBalliBaba What do you think about the actual solution? |
rw.(http.Flusher).Flush() | ||
|
||
if f, ok := rw.(http.Flusher); ok { | ||
f.Flush() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
f.Flush() | |
f.Flush() |
@@ -225,6 +225,7 @@ func (worker *worker) handleRequest(fc *frankenPHPContext) { | |||
case scaleChan <- fc: | |||
// the request has triggered scaling, continue to wait for a thread | |||
case <-timeoutChan(maxWaitTime): | |||
metrics.DequeuedWorkerRequest(worker.name) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good 👍, you can probably also add this line in threadregular.go (for non-worker requests)
Description
Fixes (#1539 (comment))