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

Change complimentary_task to complementary_tas

Browse Source 
Closes #11
This commit is contained in:
vijeth-aradhya 2017-08-29 11:26:12 +05:30
parent 7fb50b7a21
commit f1cdf74202
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mediagoblin/media_types/video/processing.py
View File

@ -185,7 +185,7 @@ def main_task(entry_id, resolution, medium_size, **process_info):
@celery.task() @celery.task()
def complimentary_task(entry_id, resolution, medium_size, **process_info): def complementary_task(entry_id, resolution, medium_size, **process_info):
""" """
Side celery task to transcode the video to other resolutions Side celery task to transcode the video to other resolutions
""" """
@ -595,7 +595,7 @@ class VideoProcessingManager(ProcessingManager):
if comp_res != def_res: if comp_res != def_res:
priority_num += -1 priority_num += -1
tasks_list.append( tasks_list.append(
complimentary_task.signature(args=(entry.id, comp_res, complementary_task.signature(args=(entry.id, comp_res,
ACCEPTED_RESOLUTIONS[comp_res]), ACCEPTED_RESOLUTIONS[comp_res]),
kwargs=reprocess_info, queue='default', kwargs=reprocess_info, queue='default',
priority=priority_num, immutable=True) priority=priority_num, immutable=True)

8
mediagoblin/tests/test_submission.py
View File

@ -61,7 +61,7 @@ from mediagoblin.tools import template
from mediagoblin.media_types.image import ImageMediaManager from mediagoblin.media_types.image import ImageMediaManager
from mediagoblin.media_types.pdf.processing import check_prerequisites as pdf_check_prerequisites from mediagoblin.media_types.pdf.processing import check_prerequisites as pdf_check_prerequisites
from mediagoblin.media_types.video.processing import ( from mediagoblin.media_types.video.processing import (
VideoProcessingManager, main_task, complimentary_task, group, VideoProcessingManager, main_task, complementary_task, group,
processing_cleanup, CommonVideoProcessor) processing_cleanup, CommonVideoProcessor)
from mediagoblin.media_types.video.util import ACCEPTED_RESOLUTIONS from mediagoblin.media_types.video.util import ACCEPTED_RESOLUTIONS
from mediagoblin.submit.lib import new_upload_entry, run_process_media from mediagoblin.submit.lib import new_upload_entry, run_process_media
@ -602,7 +602,7 @@ class TestSubmissionVideo(BaseTestSubmission):
assert result[i][2] == media_file.file_path assert result[i][2] == media_file.file_path
@mock.patch('mediagoblin.media_types.video.processing.processing_cleanup.signature') @mock.patch('mediagoblin.media_types.video.processing.processing_cleanup.signature')
@mock.patch('mediagoblin.media_types.video.processing.complimentary_task.signature') @mock.patch('mediagoblin.media_types.video.processing.complementary_task.signature')
@mock.patch('mediagoblin.media_types.video.processing.main_task.signature') @mock.patch('mediagoblin.media_types.video.processing.main_task.signature')
def test_celery_tasks(self, mock_main_task, mock_comp_task, mock_cleanup): def test_celery_tasks(self, mock_main_task, mock_comp_task, mock_cleanup):
@ -674,7 +674,7 @@ class TestSubmissionVideo(BaseTestSubmission):
if comp_res != def_res: if comp_res != def_res:
priority_num += -1 priority_num += -1
tasks_list.append( tasks_list.append(
complimentary_task.signature(args=(entry.id, comp_res, complementary_task.signature(args=(entry.id, comp_res,
ACCEPTED_RESOLUTIONS[comp_res]), ACCEPTED_RESOLUTIONS[comp_res]),
kwargs=reprocess_info, queue='default', kwargs=reprocess_info, queue='default',
priority=priority_num, immutable=True) priority=priority_num, immutable=True)
@ -709,7 +709,7 @@ class TestSubmissionVideo(BaseTestSubmission):
if comp_res != def_res: if comp_res != def_res:
priority_num += -1 priority_num += -1
tasks_list.append( tasks_list.append(
complimentary_task.signature(args=(entry.id, comp_res, complementary_task.signature(args=(entry.id, comp_res,
ACCEPTED_RESOLUTIONS[comp_res]), ACCEPTED_RESOLUTIONS[comp_res]),
kwargs=reprocess_info, queue='default', kwargs=reprocess_info, queue='default',
priority=priority_num, immutable=True) priority=priority_num, immutable=True)