Add complimentary_tasks to the celery group

Add a couple of complimentary_tasks to check if priority is
working or not.

diff --git a/mediagoblin/media_types/video/processing.py b/mediagoblin/media_types/video/processing.py
index a59a7c0b465688dcf2385c11f4e8f9f68babb9ed..586a0c85e9ab536972a3aa16eb464bd693ea94d5 100644 (file)
--- 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)