From 4e6745f3c14039121dc8c352c9e3ef2e54bf8bbf Mon Sep 17 00:00:00 2001 From: Kevin Falcone Date: Wed, 11 Jan 2017 16:45:03 -0500 Subject: [PATCH] These tasks tend to be very short but can queue behind grade reports Here are the 3 tasks over the last 30 days with average duration runtimes in seconds: lms.djangoapps.instructor_task.tasks.calculate_students_features_csv 37.794393 lms.djangoapps.instructor_task.tasks.calculate_may_enroll_csv 0.030303 lms.djangoapps.instructor_task.tasks.export_ora2_data 67.629921 All but ora2 seem fine to pass through the default queue, which has 3 workers per physical machine. --- lms/djangoapps/instructor_task/tasks.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lms/djangoapps/instructor_task/tasks.py b/lms/djangoapps/instructor_task/tasks.py index 5a24516701..7ad7cf2a60 100644 --- a/lms/djangoapps/instructor_task/tasks.py +++ b/lms/djangoapps/instructor_task/tasks.py @@ -193,7 +193,7 @@ def calculate_problem_grade_report(entry_id, xmodule_instance_args): return run_main_task(entry_id, task_fn, action_name) -@task(base=BaseInstructorTask, routing_key=settings.GRADES_DOWNLOAD_ROUTING_KEY) # pylint: disable=not-callable +@task(base=BaseInstructorTask) # pylint: disable=not-callable def calculate_students_features_csv(entry_id, xmodule_instance_args): """ Compute student profile information for a course and upload the @@ -252,7 +252,7 @@ def proctored_exam_results_csv(entry_id, xmodule_instance_args): return run_main_task(entry_id, task_fn, action_name) -@task(base=BaseInstructorTask, routing_key=settings.GRADES_DOWNLOAD_ROUTING_KEY) # pylint: disable=not-callable +@task(base=BaseInstructorTask) # pylint: disable=not-callable def calculate_may_enroll_csv(entry_id, xmodule_instance_args): """ Compute information about invited students who have not enrolled @@ -293,7 +293,7 @@ def cohort_students(entry_id, xmodule_instance_args): return run_main_task(entry_id, task_fn, action_name) -@task(base=BaseInstructorTask, routing_key=settings.GRADES_DOWNLOAD_ROUTING_KEY) # pylint: disable=not-callable +@task(base=BaseInstructorTask) # pylint: disable=not-callable def export_ora2_data(entry_id, xmodule_instance_args): """ Generate a CSV of ora2 responses and push it to S3.