mirror of
https://github.com/getredash/redash.git
synced 2025-12-29 11:00:14 -05:00
32 lines
866 B
Python
32 lines
866 B
Python
from celery import Celery
|
|
from datetime import timedelta
|
|
from redash import settings
|
|
|
|
|
|
celery = Celery('redash',
|
|
broker=settings.CELERY_BROKER,
|
|
include='redash.tasks')
|
|
|
|
celery_schedule = {
|
|
'refresh_queries': {
|
|
'task': 'redash.tasks.refresh_queries',
|
|
'schedule': timedelta(seconds=30)
|
|
},
|
|
'cleanup_tasks': {
|
|
'task': 'redash.tasks.cleanup_tasks',
|
|
'schedule': timedelta(minutes=5)
|
|
}
|
|
}
|
|
|
|
if settings.QUERY_RESULTS_CLEANUP_ENABLED:
|
|
celery_schedule['cleanup_query_results'] = {
|
|
'task': 'redash.tasks.cleanup_query_results',
|
|
'schedule': timedelta(minutes=5)
|
|
}
|
|
|
|
celery.conf.update(CELERY_RESULT_BACKEND=settings.CELERY_BACKEND,
|
|
CELERYBEAT_SCHEDULE=celery_schedule,
|
|
CELERY_TIMEZONE='UTC')
|
|
|
|
if __name__ == '__main__':
|
|
celery.start() |