- 
          
 - 
                Notifications
    
You must be signed in to change notification settings  - Fork 377
 
GSK-1863 : Using multiprocess instead of threading #1469
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
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
  
    | 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.mddocument.CONTRIBUTING.mdguide.make codestyle.