Merge branch 'master' into OPW-Moderation-Update
Conflicts: mediagoblin/db/models.py mediagoblin/decorators.py mediagoblin/routing.py mediagoblin/user_pages/views.py
This commit is contained in:
@@ -21,7 +21,7 @@ from werkzeug.datastructures import FileStorage
|
||||
|
||||
from mediagoblin.db.models import MediaEntry
|
||||
from mediagoblin.processing import mark_entry_failed
|
||||
from mediagoblin.processing.task import process_media
|
||||
from mediagoblin.processing.task import ProcessMedia
|
||||
|
||||
|
||||
_log = logging.getLogger(__name__)
|
||||
@@ -85,7 +85,7 @@ def run_process_media(entry, feed_url=None):
|
||||
'mediagoblin.user_pages.atom_feed',qualified=True,
|
||||
user=request.user.username)`"""
|
||||
try:
|
||||
process_media.apply_async(
|
||||
ProcessMedia().apply_async(
|
||||
[entry.id, feed_url], {},
|
||||
task_id=entry.queued_task_id)
|
||||
except BaseException as exc:
|
||||
|
||||
@@ -90,7 +90,7 @@ def submit_start(request):
|
||||
# Save now so we have this data before kicking off processing
|
||||
entry.save()
|
||||
|
||||
# Pass off to processing
|
||||
# Pass off to async processing
|
||||
#
|
||||
# (... don't change entry after this point to avoid race
|
||||
# conditions with changes to the document via processing code)
|
||||
@@ -98,6 +98,7 @@ def submit_start(request):
|
||||
'mediagoblin.user_pages.atom_feed',
|
||||
qualified=True, user=request.user.username)
|
||||
run_process_media(entry, feed_url)
|
||||
|
||||
add_message(request, SUCCESS, _('Woohoo! Submitted!'))
|
||||
|
||||
add_comment_subscription(request.user, entry)
|
||||
|
||||
Reference in New Issue
Block a user