-
Notifications
You must be signed in to change notification settings - Fork 13.9k
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
Use sane Celery defaults to prevent tasks from being delayed #3267
Use sane Celery defaults to prevent tasks from being delayed #3267
Conversation
Coverage remained the same at 69.301% when pulling 5896dd3726661b8c52f17d344d8997420f4b0329 on saguziel:aguziel-celery-fix-defaults into 327c052 on apache:master. |
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.
Notice how our pylint --errors
caught a hard-to-catch-on-review bug on Travis?!
Would definitely recommend setting up something similar for Airflow. pylint does some deep analysis of the code and will catch logic and type errors.
superset/cli.py
Outdated
@@ -194,7 +194,7 @@ def worker(workers): | |||
celery_app.conf.update( | |||
CELERYD_CONCURRENCY=config.get("SUPERSET_CELERY_WORKERS")) | |||
|
|||
worker = celery_worker.worker(app=celery_app) | |||
worker = app.Worker(optimization='fair') |
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.
app
in this context is the Flask app, not celery_app
5896dd3
to
8e90435
Compare
* split reducer logic for ExploreViewContainer * fix saveModal component and unit tests * revert changes in SaveModal_spec. will make another commit just to improve test coverage for SaveModal component. * improve test coverage for explore view components: - SaveModal component - URLShortLinkButton * remove comment-out code * [bugfix] wrong 'Cant have overlap between Series and Breakdowns' (#3254) * [explore] make edit datasource a basic link (#3244) * Relying on FAB for font-awesome.min.css (#3261) * Modernize SQLA pessimistic handling (#3256) Looks like SQLAlchemy has redefined the best practice around pessimistic connection handling. * [webpack] break CSS and JS files while webpackin' (#3262) * [webpack] break CSS and JS files while webpackin' * cleaning up some templates * Fix pylint issue * import logging (#3264) * [bugfix] preserve order in groupby (#3268) Recently in 4c3313b I introduced an issue where the order of groupby fields might change. This addresses this issue and will preserve ordering. * Explicitly add Flask as dependancy (#3252) * Use sane Celery defaults to prevent tasks from being delayed (#3267) * Improve the chart type of Visualize in sqllab (#3241) * Improve the chart type of Visualize in sqllab & Add some css & Fix the link address in the navbar * add vizTypes filter * Set default ports Druid (#3266) For Druid set the default port for the broker and coordinator. * [explore] Split large reducer logic in ExploreViewContainer (#3088) * split reducer logic for ExploreViewContainer * fix saveModal component and unit tests * revert changes in SaveModal_spec. will make another commit just to improve test coverage for SaveModal component. * remove comment-out code * fix merge confilicts
@mistercrunch
Using these three settings (of which two are provided in the config to show it's recommended), will make Celery scheduling "fair", which reduces latency which is what is wanted when we have long running tasks (note that the defaults prioritize throughput in the case with high volumes of short-running tasks)
Still need to test this