diff options
| -rw-r--r-- | mediagoblin/media_types/video/processing.py | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/mediagoblin/media_types/video/processing.py b/mediagoblin/media_types/video/processing.py index a59a7c0b..586a0c85 100644 --- a/mediagoblin/media_types/video/processing.py +++ b/mediagoblin/media_types/video/processing.py @@ -191,7 +191,7 @@ def complimentary_task(entry_id, resolution, medium_size, **process_info): @celery.task() def processing_cleanup(entry_id): - print "\nEnter processing_cleanup()\n" + print "\nEntered processing_cleanup()\n" entry, manager = get_entry_and_processing_manager(entry_id) with CommonVideoProcessor(manager, entry) as processor: processor.delete_queue_file() @@ -559,18 +559,18 @@ class VideoProcessingManager(ProcessingManager): main_task.signature(args=(entry_id, '480p', ACCEPTED_RESOLUTIONS['480p']), kwargs=reprocess_info, queue='default', priority=5, immutable=True), - ]) - - cleanup_task = processing_cleanup.signature(args=(entry_id,), - queue='default', immutable=True) - - """ complimentary_task.signature(args=(entry_id, '360p', ACCEPTED_RESOLUTIONS['360p']), kwargs=reprocess_info, queue='default', priority=4, immutable=True), complimentary_task.signature(args=(entry_id, '720p', ACCEPTED_RESOLUTIONS['720p']), kwargs=reprocess_info, queue='default', priority=3, immutable=True), + ]) + + cleanup_task = processing_cleanup.signature(args=(entry_id,), + queue='default', immutable=True) + + """ main_task.apply_async(args=(entry_id, '480p', ACCEPTED_RESOLUTIONS['480p']), kwargs=reprocess_info, queue='default', priority=5, immutable=True) @@ -578,6 +578,3 @@ class VideoProcessingManager(ProcessingManager): """ chord(transcoding_tasks)(cleanup_task) - - # main_task(entry_id, '480p', ACCEPTED_RESOLUTIONS['480p'], **reprocess_info) - # processing_cleanup(entry_id) |