Add priority to the celery tasks
[mediagoblin.git] / mediagoblin / media_types / image / processing.py
index 42234eff12288c778e2974a92203bdf3e6313888..a189fef3e7f09fb163e270e0df9ea25f467a1f8e 100644 (file)
@@ -431,7 +431,8 @@ class ImageProcessingManager(ProcessingManager):
         self.add_processor(Resizer)
         self.add_processor(MetadataProcessing)
 
-    def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
+    def workflow(self, entry, manager, feed_url, reprocess_action,
+                 reprocess_info=None):
         ProcessMedia().apply_async(
             [entry.id, feed_url, reprocess_action, reprocess_info], {},
             task_id=entry.queued_task_id)