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
When investigating #7655, I got the suspicion that we may have a bottleneck caused by the fact that there's only one worker in the offload executor.
Additionally, there's a known issue (#5882) where, whenever a task calls rejoin(), you will have one less thread available then what the WorkerStateMachine believes is available, which will cause Worker.execute to get stuck for a long time on the call to run_in_executor.
In both cases, as of #7586 this time is displayed as ("execute", <prefix>, "other", "seconds").
Wrap these two calls to run_in_executor in with context_meter.meter("offload") and with context_meter.meter("executor") respectively.
The text was updated successfully, but these errors were encountered:
executing
upon rejoining. #5882When investigating #7655, I got the suspicion that we may have a bottleneck caused by the fact that there's only one worker in the offload executor.
Additionally, there's a known issue (#5882) where, whenever a task calls
rejoin()
, you will have one less thread available then what the WorkerStateMachine believes is available, which will causeWorker.execute
to get stuck for a long time on the call torun_in_executor
.In both cases, as of #7586 this time is displayed as
("execute", <prefix>, "other", "seconds")
.Wrap these two calls to
run_in_executor
inwith context_meter.meter("offload")
andwith context_meter.meter("executor")
respectively.The text was updated successfully, but these errors were encountered: