-
-
Notifications
You must be signed in to change notification settings - Fork 289
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
GSK-1863 : Using multiprocess instead of threading #1469
GSK-1863 : Using multiprocess instead of threading #1469
Conversation
GSK-1863 Using get similar examples on Enron seems to stuck the server/worker ?
Getting the insights on Enron is really slow, but whenclicking on get similar data, it looks like is getting stuck on some computations ? CPU usage is not that high, using only 1 cpu |
11d7440
to
44191d5
Compare
ac378ad
to
8a8edf2
Compare
# Post-processing of stopWorker | ||
if action == MLWorkerAction.stopWorker and ml_worker.ws_stopping is True: | ||
ml_worker.ws_conn.disconnect() | ||
return | ||
|
||
|
||
def websocket_actor(action: MLWorkerAction): |
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.
Did you decide not to add a execute_in_pool
boolean flag to this decorator?
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.
Good idea for some quick and short task
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.
Yeah, I forgot about that since I had issues with the enron. Just added
logger.debug(f'Registered "{callback.__name__}" for ML Worker "{action.name}"') | ||
|
||
def wrapped_callback(ml_worker: MLWorker, req: dict, *args, **kwargs): | ||
dispatch_action(callback, ml_worker, action, req) |
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.
in case execute_in_pool
is added it would need to be passed here
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.
👍
8a8edf2
to
c821df9
Compare
Contributes to #GSK-1863
c821df9
to
5dc0701
Compare
Kudos, SonarCloud Quality Gate passed! |
Description
Related Issue
Type of Change
Checklist
CODE_OF_CONDUCT.md
document.CONTRIBUTING.md
guide.make codestyle
.