Merge remote-tracking branch 'refs/remotes/rodney757/reprocessing'

[mediagoblin.git] / mediagoblin / submit / lib.py

diff --git a/mediagoblin/submit/lib.py b/mediagoblin/submit/lib.py
index 1a45e44796767b8cc4b281b5376fcf3cdbff3a9e..1bbf2cb8ef013fe846e1cb841c7f5c58ed443df7 100644 (file)
--- a/mediagoblin/submit/lib.py
+++ b/mediagoblin/submit/lib.py
@@ -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__)
@@ -89,7 +89,7 @@ def run_process_media(entry, feed_url=None,
     :param reprocess_info: A dict containing all of the necessary reprocessing
         info for the given media_type"""
     try:
-        process_media.apply_async(
+        ProcessMedia().apply_async(
             [entry.id, feed_url, reprocess_action, reprocess_info], {},
             task_id=entry.queued_task_id)
     except BaseException as exc: