diff --git a/cms/envs/aws.py b/cms/envs/aws.py
index b41460fa3d..fdf08b2e48 100644
--- a/cms/envs/aws.py
+++ b/cms/envs/aws.py
@@ -500,4 +500,4 @@ AFFILIATE_COOKIE_NAME = ENV_TOKENS.get('AFFILIATE_COOKIE_NAME', AFFILIATE_COOKIE
 HELP_TOKENS_BOOKS = ENV_TOKENS.get('HELP_TOKENS_BOOKS', HELP_TOKENS_BOOKS)
 
 ############## Settings for CourseGraph ############################
-COURSEGRAPH_JOB_QUEUE = LOW_PRIORITY_QUEUE
+COURSEGRAPH_JOB_QUEUE = ENV_TOKENS.get('COURSEGRAPH_JOB_QUEUE', LOW_PRIORITY_QUEUE)
diff --git a/lms/envs/aws.py b/lms/envs/aws.py
index d689475dbb..afd085d000 100644
--- a/lms/envs/aws.py
+++ b/lms/envs/aws.py
@@ -1001,4 +1001,4 @@ COURSES_API_CACHE_TIMEOUT = ENV_TOKENS.get('COURSES_API_CACHE_TIMEOUT', COURSES_
 ICP_LICENSE = ENV_TOKENS.get('ICP_LICENSE', None)
 
 ############## Settings for CourseGraph ############################
-COURSEGRAPH_JOB_QUEUE = LOW_PRIORITY_QUEUE
+COURSEGRAPH_JOB_QUEUE = ENV_TOKENS.get('COURSEGRAPH_JOB_QUEUE', LOW_PRIORITY_QUEUE)
diff --git a/openedx/core/djangoapps/coursegraph/tasks.py b/openedx/core/djangoapps/coursegraph/tasks.py
index ba5709f2c2..c8c0d23df3 100644
--- a/openedx/core/djangoapps/coursegraph/tasks.py
+++ b/openedx/core/djangoapps/coursegraph/tasks.py
@@ -225,7 +225,7 @@ def should_dump_course(course_key, graph):
     return last_this_command_was_run < course_last_published_date
 
 
-@task
+@task(routing_key=settings.COURSEGRAPH_JOB_QUEUE)
 def dump_course_to_neo4j(course_key_string, credentials):
     """
     Serializes a course and writes it to neo4j.
@@ -341,7 +341,6 @@ class ModuleStoreSerializer(object):
 
             dump_course_to_neo4j.apply_async(
                 args=[six.text_type(course_key), credentials],
-                routing_key=settings.COURSEGRAPH_JOB_QUEUE,
             )
             submitted_courses.append(six.text_type(course_key))