- 
                Notifications
    
You must be signed in to change notification settings  - Fork 32
 
🎨🐛 Fix filtering bug in celery tasks #8355
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
🎨🐛 Fix filtering bug in celery tasks #8355
Conversation
          Codecov Report❌ Patch coverage is  Additional details and impacted files@@            Coverage Diff             @@
##           master    #8355      +/-   ##
==========================================
+ Coverage   87.83%   87.88%   +0.05%     
==========================================
  Files        1945     1944       -1     
  Lines       75582    75603      +21     
  Branches     1314     1316       +2     
==========================================
+ Hits        66389    66447      +58     
+ Misses       8796     8759      -37     
  Partials      397      397              
 
 Continue to review full report in Codecov by Sentry. 
 🚀 New features to boost your workflow:
  | 
    
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.
very nice! thanks!
        
          
                packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/storage/_utils.py
              
                Outdated
          
            Show resolved
            Hide resolved
        
              
          
                services/api-server/src/simcore_service_api_server/api/dependencies/celery.py
              
                Outdated
          
            Show resolved
            Hide resolved
        
              
          
                services/storage/src/simcore_service_storage/api/rest/_files.py
              
                Outdated
          
            Show resolved
            Hide resolved
        
      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.
nice, just a questions
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.
thx
          
 | 
    
| 
           @Mergifyio queue  | 
    
          
 🟠 Waiting for conditions to match
  | 
    



What do these changes do?
TaskFilteringclass which meant that all users had access to all celery tasks anywhere 😱. This is because extra fields were ignored in that model. This PR changes that and allows them.TaskContextdata structure to aTaskFilter#8071). The functionality for doing so is all done in theTaskFilterclass.TaskFiltersto check that inputs are compatible with the assumptions we require to build Redis keys.client_namevariable inAsyncJobFilter, so I corrected that (which is crucial for listing)Related issue/s
TaskContextdata structure to aTaskFilter#8071How to test
packages/service-library/tests/test_celery.pypackages/celery-library/tests/unit/test_tasks.pyDev-ops