You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We should merge this together and have one method, which will either:
Fail immediately if the request validation fails
Block for the whole duration of the job, meaning the method should do the wait on the CompletedChannel. The reason for doing it, if any user of the api forgets to wait on the channel, the worker for that request will block indefinitely and there will be less workers in balancer. Balancer unknowingly will queue new work for that worker and when the buffer fills up, it will block also.
The text was updated successfully, but these errors were encountered:
Currently, we post new job to balancer and wait on the request CompletedChannel from the user side, like this:
balancer.PostJob(request)
<-request.CompletedChannel
We should merge this together and have one method, which will either:
The text was updated successfully, but these errors were encountered: