Updated raven plugin
[mediagoblin.git] / mediagoblin / init / celery / __init__.py
index fc595ea77bb671998ff218ca35de6f0c45a185d3..8d7a41bdaf7a617ebcbe17d38b9eced48cffeadd 100644 (file)
@@ -18,6 +18,7 @@ import os
 import sys
 
 from celery import Celery
+from mediagoblin.tools.pluginapi import PluginManager
 
 
 MANDATORY_CELERY_IMPORTS = ['mediagoblin.processing.task']
@@ -65,6 +66,9 @@ def setup_celery_app(app_config, global_config,
     celery_app = Celery()
     celery_app.config_from_object(celery_settings)
 
+    for callable_hook in PluginManager().get_hook_callables('celery_setup'):
+        callable_hook(celery_app)
+
 
 def setup_celery_from_config(app_config, global_config,
                              settings_module=DEFAULT_SETTINGS_MODULE,