diff options
| author | Jessica Tallon <jessica@megworld.co.uk> | 2014-07-23 00:23:23 +0100 |
|---|---|---|
| committer | Jessica Tallon <jessica@megworld.co.uk> | 2014-07-23 00:23:23 +0100 |
| commit | aab62394773c27e73996e8cb8fb425db3fa62d49 (patch) | |
| tree | 5f7e8a14f557f9917179fc8f2d4e9987ef98097a /mediagoblin/init/celery | |
| parent | 59ff4790c9f33fe13ee0a411d4152bd256eaa06a (diff) | |
| parent | a14d90c2db5ff96bdd72009a07f1afc0e8ef3595 (diff) | |
| download | mediagoblin-aab62394773c27e73996e8cb8fb425db3fa62d49.tar.lz mediagoblin-aab62394773c27e73996e8cb8fb425db3fa62d49.tar.xz mediagoblin-aab62394773c27e73996e8cb8fb425db3fa62d49.zip | |
Merge branch 'Federation'
Diffstat (limited to 'mediagoblin/init/celery')
| -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..2f2c40d3 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(frequency) + 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 |