diff options
| author | Jessica Tallon <jessica@megworld.co.uk> | 2014-07-15 21:24:25 +0100 |
|---|---|---|
| committer | Jessica Tallon <jessica@megworld.co.uk> | 2014-07-22 23:13:16 +0100 |
| commit | 0679545f192d8d45a4d98c65bf731e236d73b418 (patch) | |
| tree | 173eea3235fa3e2d933477296d17bd57aa24e6dc /mediagoblin/init/celery/__init__.py | |
| parent | 0e283215bd2938f665930f3c481a6003d74bb845 (diff) | |
| download | mediagoblin-0679545f192d8d45a4d98c65bf731e236d73b418.tar.lz mediagoblin-0679545f192d8d45a4d98c65bf731e236d73b418.tar.xz mediagoblin-0679545f192d8d45a4d98c65bf731e236d73b418.zip | |
Add garbage collection task
Diffstat (limited to 'mediagoblin/init/celery/__init__.py')
| -rw-r--r-- | mediagoblin/init/celery/__init__.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/mediagoblin/init/celery/__init__.py b/mediagoblin/init/celery/__init__.py index 57242bf6..214d00c3 100644 --- a/mediagoblin/init/celery/__init__.py +++ b/mediagoblin/init/celery/__init__.py @@ -16,6 +16,7 @@ import os import sys +import datetime import logging from celery import Celery @@ -58,6 +59,18 @@ def get_celery_settings_dict(app_config, global_config, celery_settings['CELERY_ALWAYS_EAGER'] = True celery_settings['CELERY_EAGER_PROPAGATES_EXCEPTIONS'] = True + # Garbage collection periodic task + frequency = app_config.get('garbage_collection', 60) + if frequency: + frequency = int(app_config['garbage_collection']) + celery_settings['CELERYBEAT_SCHEDULE'] = { + 'garbage-collection': { + 'task': 'mediagoblin.federation.task.garbage_collection', + 'schedule': datetime.timedelta(minutes=frequency), + } + } + celery_settings['BROKER_HEARTBEAT'] = 1 + return celery_settings |