Skip to content
Snippets Groups Projects
Commit 68e760ff authored by Qubad786's avatar Qubad786 Committed by M. Rehan
Browse files

Move transcript migrations tasks to low priority queue

parent 10dd775e
No related branches found
No related tags found
No related merge requests found
...@@ -84,7 +84,7 @@ COURSE_LEVEL_TIMEOUT_SECONDS = 1200 ...@@ -84,7 +84,7 @@ COURSE_LEVEL_TIMEOUT_SECONDS = 1200
VIDEO_LEVEL_TIMEOUT_SECONDS = 300 VIDEO_LEVEL_TIMEOUT_SECONDS = 300
@chord_task(bind=True) @chord_task(bind=True, routing_key=settings.VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE)
def task_status_callback(self, results, revision, # pylint: disable=unused-argument def task_status_callback(self, results, revision, # pylint: disable=unused-argument
course_id, command_run, video_location): course_id, command_run, video_location):
""" """
...@@ -157,7 +157,8 @@ def get_course_videos(course_key): ...@@ -157,7 +157,8 @@ def get_course_videos(course_key):
base=LoggedPersistOnFailureTask, base=LoggedPersistOnFailureTask,
default_retry_delay=RETRY_DELAY_SECONDS, default_retry_delay=RETRY_DELAY_SECONDS,
max_retries=1, max_retries=1,
time_limit=COURSE_LEVEL_TIMEOUT_SECONDS time_limit=COURSE_LEVEL_TIMEOUT_SECONDS,
routing_key=settings.VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE
) )
def async_migrate_transcript(self, course_key, **kwargs): # pylint: disable=unused-argument def async_migrate_transcript(self, course_key, **kwargs): # pylint: disable=unused-argument
""" """
...@@ -251,7 +252,8 @@ def save_transcript_to_storage(command_run, edx_video_id, language_code, transcr ...@@ -251,7 +252,8 @@ def save_transcript_to_storage(command_run, edx_video_id, language_code, transcr
base=LoggedPersistOnFailureTask, base=LoggedPersistOnFailureTask,
default_retry_delay=RETRY_DELAY_SECONDS, default_retry_delay=RETRY_DELAY_SECONDS,
max_retries=2, max_retries=2,
time_limit=VIDEO_LEVEL_TIMEOUT_SECONDS time_limit=VIDEO_LEVEL_TIMEOUT_SECONDS,
routing_key=settings.VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE
) )
def async_migrate_transcript_subtask(self, *args, **kwargs): # pylint: disable=unused-argument def async_migrate_transcript_subtask(self, *args, **kwargs): # pylint: disable=unused-argument
""" """
......
...@@ -546,6 +546,9 @@ HELP_TOKENS_BOOKS = ENV_TOKENS.get('HELP_TOKENS_BOOKS', HELP_TOKENS_BOOKS) ...@@ -546,6 +546,9 @@ HELP_TOKENS_BOOKS = ENV_TOKENS.get('HELP_TOKENS_BOOKS', HELP_TOKENS_BOOKS)
############## Settings for CourseGraph ############################ ############## Settings for CourseGraph ############################
COURSEGRAPH_JOB_QUEUE = ENV_TOKENS.get('COURSEGRAPH_JOB_QUEUE', LOW_PRIORITY_QUEUE) COURSEGRAPH_JOB_QUEUE = ENV_TOKENS.get('COURSEGRAPH_JOB_QUEUE', LOW_PRIORITY_QUEUE)
########## Settings for video transcript migration tasks ############
VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE = ENV_TOKENS.get('VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE', LOW_PRIORITY_QUEUE)
########################## Parental controls config ####################### ########################## Parental controls config #######################
# The age at which a learner no longer requires parental consent, or None # The age at which a learner no longer requires parental consent, or None
......
...@@ -1494,6 +1494,9 @@ POLICY_CHANGE_TASK_RATE_LIMIT = '300/h' ...@@ -1494,6 +1494,9 @@ POLICY_CHANGE_TASK_RATE_LIMIT = '300/h'
############## Settings for CourseGraph ############################ ############## Settings for CourseGraph ############################
COURSEGRAPH_JOB_QUEUE = LOW_PRIORITY_QUEUE COURSEGRAPH_JOB_QUEUE = LOW_PRIORITY_QUEUE
########## Settings for video transcript migration tasks ############
VIDEO_TRANSCRIPT_MIGRATIONS_JOB_QUEUE = LOW_PRIORITY_QUEUE
###################### VIDEO IMAGE STORAGE ###################### ###################### VIDEO IMAGE STORAGE ######################
VIDEO_IMAGE_DEFAULT_FILENAME = 'images/video-images/default_video_image.png' VIDEO_IMAGE_DEFAULT_FILENAME = 'images/video-images/default_video_image.png'
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment