aboutsummaryrefslogtreecommitdiffstats
path: root/mediagoblin/celery_setup/from_celery.py
diff options
context:
space:
mode:
authorChristopher Allan Webber <cwebber@dustycloud.org>2011-06-11 19:47:02 -0500
committerChristopher Allan Webber <cwebber@dustycloud.org>2011-06-11 19:47:02 -0500
commit7ecc58cc5cf49c87001c38ba5d0607644ca195d4 (patch)
tree5a60b13652f420524e9f5df17cd3f0b41d72ef61 /mediagoblin/celery_setup/from_celery.py
parentf43ecb0fc459c0ee64f3a40b98ed6bbf8564c107 (diff)
downloadmediagoblin-7ecc58cc5cf49c87001c38ba5d0607644ca195d4.tar.lz
mediagoblin-7ecc58cc5cf49c87001c38ba5d0607644ca195d4.tar.xz
mediagoblin-7ecc58cc5cf49c87001c38ba5d0607644ca195d4.zip
Have the application set up instances of the WorkbenchManager.
Diffstat (limited to 'mediagoblin/celery_setup/from_celery.py')
-rw-r--r--mediagoblin/celery_setup/from_celery.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/mediagoblin/celery_setup/from_celery.py b/mediagoblin/celery_setup/from_celery.py
index 0669e80c..e1216815 100644
--- a/mediagoblin/celery_setup/from_celery.py
+++ b/mediagoblin/celery_setup/from_celery.py
@@ -23,7 +23,8 @@ from mediagoblin import storage
from mediagoblin.db.open import setup_connection_and_db_from_config
from mediagoblin.celery_setup import setup_celery_from_config
from mediagoblin.globals import setup_globals
-from mediagoblin import globals as mgoblin_globals
+from mediagoblin.process_media.workbench import (
+ WorkbenchManager, DEFAULT_WORKBENCH_DIR)
OUR_MODULENAME = 'mediagoblin.celery_setup.from_celery'
@@ -76,6 +77,10 @@ def setup_self(setup_globals_func=setup_globals):
queue_store = storage.storage_system_from_paste_config(
mgoblin_section, 'queuestore')
+ workbench_manager = WorkbenchManager(
+ mgoblin_section.get(
+ 'workbench_path', DEFAULT_WORKBENCH_DIR))
+
setup_globals_func(
db_connection=connection,
database=db,
@@ -84,7 +89,8 @@ def setup_self(setup_globals_func=setup_globals):
email_sender_address=mgoblin_section.get(
'email_sender_address',
'notice@mediagoblin.example.org'),
- queue_store=queue_store)
+ queue_store=queue_store,
+ workbench_manager=workbench_manager)
if os.environ['CELERY_CONFIG_MODULE'] == OUR_MODULENAME: