projects
/
mediagoblin.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Switch over media processor to use the get_workbench decorator (#565)
[mediagoblin.git]
/
mediagoblin
/
media_types
/
ascii
/
processing.py
diff --git
a/mediagoblin/media_types/ascii/processing.py
b/mediagoblin/media_types/ascii/processing.py
index 04d1166c46b33af73531ee92e9c5a106ee800fa2..254717ebf725ab627819e0ca1688a0e41f0515ee 100644
(file)
--- a/
mediagoblin/media_types/ascii/processing.py
+++ b/
mediagoblin/media_types/ascii/processing.py
@@
-19,6
+19,7
@@
import Image
import logging
from mediagoblin import mg_globals as mgg
import logging
from mediagoblin import mg_globals as mgg
+from mediagoblin.decorators import get_workbench
from mediagoblin.processing import create_pub_filepath
from mediagoblin.media_types.ascii import asciitoimage
from mediagoblin.processing import create_pub_filepath
from mediagoblin.media_types.ascii import asciitoimage
@@
-38,12
+39,14
@@
def sniff_handler(media_file, **kw):
return False
return False
-def process_ascii(entry):
- '''
- Code to process a txt file
- '''
+@get_workbench
+def process_ascii(entry, workbench=None):
+ """Code to process a txt file. Will be run by celery.
+
+ A Workbench() represents a local tempory dir. It is automatically
+ cleaned up when this function exits.
+ """
ascii_config = mgg.global_config['media_type:mediagoblin.media_types.ascii']
ascii_config = mgg.global_config['media_type:mediagoblin.media_types.ascii']
- workbench = mgg.workbench_manager.create_workbench()
# Conversions subdirectory to avoid collisions
conversions_subdir = os.path.join(
workbench.dir, 'conversions')
# Conversions subdirectory to avoid collisions
conversions_subdir = os.path.join(
workbench.dir, 'conversions')