diff options
| author | vijeth-aradhya <vijthaaa@gmail.com> | 2017-06-13 23:54:40 +0530 |
|---|---|---|
| committer | vijeth-aradhya <vijthaaa@gmail.com> | 2017-06-13 23:58:01 +0530 |
| commit | 869048dd15108ab379466a2df8f5fd4af1e4e068 (patch) | |
| tree | 4e3b0f96467d27faf3cfb5140f90bf89b43288f2 | |
| parent | 982fbde8e8bb6d0377e4e942a794e520774b6d72 (diff) | |
| download | mediagoblin-869048dd15108ab379466a2df8f5fd4af1e4e068.tar.lz mediagoblin-869048dd15108ab379466a2df8f5fd4af1e4e068.tar.xz mediagoblin-869048dd15108ab379466a2df8f5fd4af1e4e068.zip | |
Add complimentary_tasks to the celery group
Add a couple of complimentary_tasks to check if priority is
working or not.
| -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) |