heckyel/mediagoblin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add workflow method to other media ProcessingManagers

Browse Source 
Add workflow method to all the media types other than video.
Calls the old celery task as it is.
This commit is contained in:
vijeth-aradhya 2017-06-05 02:11:56 +05:30
parent 81c59ef06b
commit c62181f4bc
6 changed files with 31 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
mediagoblin/media_types/ascii/processing.py
View File

@ -273,3 +273,8 @@ class AsciiProcessingManager(ProcessingManager):
super(AsciiProcessingManager, self).__init__()
self.add_processor(InitialProcessor)
self.add_processor(Resizer)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)

5
mediagoblin/media_types/audio/processing.py
View File

@ -365,3 +365,8 @@ class AudioProcessingManager(ProcessingManager):
self.add_processor(InitialProcessor)
self.add_processor(Resizer)
self.add_processor(Transcoder)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)

6
mediagoblin/media_types/image/processing.py
View File

@ -431,6 +431,12 @@ class ImageProcessingManager(ProcessingManager):
self.add_processor(Resizer)
self.add_processor(MetadataProcessing)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)
if __name__ == '__main__':
import sys
import pprint

5
mediagoblin/media_types/pdf/processing.py
View File

@ -470,3 +470,8 @@ class PdfProcessingManager(ProcessingManager):
super(PdfProcessingManager, self).__init__()
self.add_processor(InitialProcessor)
self.add_processor(Resizer)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)

5
mediagoblin/media_types/raw_image/processing.py
View File

@ -80,3 +80,8 @@ class RawImageProcessingManager(ProcessingManager):
super(RawImageProcessingManager, self).__init__()
self.add_processor(InitialRawProcessor)
self.add_processor(Resizer)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)

5
mediagoblin/media_types/stl/processing.py
View File

@ -368,3 +368,8 @@ class StlProcessingManager(ProcessingManager):
super(StlProcessingManager, self).__init__()
self.add_processor(InitialProcessor)
self.add_processor(Resizer)
def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)