import sys
from celery import Celery
+from mediagoblin.tools.pluginapi import hook_runall
MANDATORY_CELERY_IMPORTS = ['mediagoblin.processing.task']
celery_app = Celery()
celery_app.config_from_object(celery_settings)
+ hook_runall('celery_setup', celery_app)
+
def setup_celery_from_config(app_config, global_config,
settings_module=DEFAULT_SETTINGS_MODULE,