Commit fc0a7614 by David Ormsbee

Load courses in dir name order, keep separate ParentTracker per course.

parent 1db70050
...@@ -345,7 +345,7 @@ class ModuleStore(object): ...@@ -345,7 +345,7 @@ class ModuleStore(object):
''' '''
raise NotImplementedError raise NotImplementedError
def get_parent_locations(self, location): def get_parent_locations(self, location, course_id):
'''Find all locations that are the parents of this location. Needed '''Find all locations that are the parents of this location. Needed
for path_to_location(). for path_to_location().
......
...@@ -309,7 +309,7 @@ class MongoModuleStore(ModuleStoreBase): ...@@ -309,7 +309,7 @@ class MongoModuleStore(ModuleStoreBase):
self._update_single_item(location, {'metadata': metadata}) self._update_single_item(location, {'metadata': metadata})
def get_parent_locations(self, location): def get_parent_locations(self, location, course_id):
'''Find all locations that are the parents of this location. Needed '''Find all locations that are the parents of this location. Needed
for path_to_location(). for path_to_location().
......
...@@ -64,7 +64,7 @@ def path_to_location(modulestore, course_id, location): ...@@ -64,7 +64,7 @@ def path_to_location(modulestore, course_id, location):
# isn't found so we don't have to do it explicitly. Call this # isn't found so we don't have to do it explicitly. Call this
# first to make sure the location is there (even if it's a course, and # first to make sure the location is there (even if it's a course, and
# we would otherwise immediately exit). # we would otherwise immediately exit).
parents = modulestore.get_parent_locations(loc) parents = modulestore.get_parent_locations(loc, course_id)
# print 'Processing loc={0}, path={1}'.format(loc, path) # print 'Processing loc={0}, path={1}'.format(loc, path)
if loc.category == "course": if loc.category == "course":
......
...@@ -275,14 +275,15 @@ class XMLModuleStore(ModuleStoreBase): ...@@ -275,14 +275,15 @@ class XMLModuleStore(ModuleStoreBase):
class_ = getattr(import_module(module_path), class_name) class_ = getattr(import_module(module_path), class_name)
self.default_class = class_ self.default_class = class_
self.parent_tracker = ParentTracker() # self.parent_tracker = ParentTracker()
self.parent_trackers = defaultdict(ParentTracker)
# If we are specifically asked for missing courses, that should # If we are specifically asked for missing courses, that should
# be an error. If we are asked for "all" courses, find the ones # be an error. If we are asked for "all" courses, find the ones
# that have a course.xml # that have a course.xml
if course_dirs is None: if course_dirs is None:
course_dirs = [d for d in os.listdir(self.data_dir) if course_dirs = sorted([d for d in os.listdir(self.data_dir) if
os.path.exists(self.data_dir / d / "course.xml")] os.path.exists(self.data_dir / d / "course.xml")])
for course_dir in course_dirs: for course_dir in course_dirs:
self.try_load_course(course_dir) self.try_load_course(course_dir)
...@@ -307,7 +308,7 @@ class XMLModuleStore(ModuleStoreBase): ...@@ -307,7 +308,7 @@ class XMLModuleStore(ModuleStoreBase):
if course_descriptor is not None: if course_descriptor is not None:
self.courses[course_dir] = course_descriptor self.courses[course_dir] = course_descriptor
self._location_errors[course_descriptor.location] = errorlog self._location_errors[course_descriptor.location] = errorlog
self.parent_tracker.make_known(course_descriptor.location) self.parent_trackers[course_descriptor.id].make_known(course_descriptor.location)
else: else:
# Didn't load course. Instead, save the errors elsewhere. # Didn't load course. Instead, save the errors elsewhere.
self.errored_courses[course_dir] = errorlog self.errored_courses[course_dir] = errorlog
...@@ -432,7 +433,7 @@ class XMLModuleStore(ModuleStoreBase): ...@@ -432,7 +433,7 @@ class XMLModuleStore(ModuleStoreBase):
course_dir, course_dir,
policy, policy,
tracker, tracker,
self.parent_tracker, self.parent_trackers[course_id],
self.load_error_modules, self.load_error_modules,
) )
...@@ -541,7 +542,7 @@ class XMLModuleStore(ModuleStoreBase): ...@@ -541,7 +542,7 @@ class XMLModuleStore(ModuleStoreBase):
""" """
raise NotImplementedError("XMLModuleStores are read-only") raise NotImplementedError("XMLModuleStores are read-only")
def get_parent_locations(self, location): def get_parent_locations(self, location, course_id):
'''Find all locations that are the parents of this location. Needed '''Find all locations that are the parents of this location. Needed
for path_to_location(). for path_to_location().
...@@ -552,7 +553,7 @@ class XMLModuleStore(ModuleStoreBase): ...@@ -552,7 +553,7 @@ class XMLModuleStore(ModuleStoreBase):
be empty if there are no parents. be empty if there are no parents.
''' '''
location = Location.ensure_fully_specified(location) location = Location.ensure_fully_specified(location)
if not self.parent_tracker.is_known(location): if not self.parent_trackers[course_id].is_known(location):
raise ItemNotFoundError(location) raise ItemNotFoundError("{0} not in {1}".format(location, course_id))
return self.parent_tracker.parents(location) return self.parent_trackers[course_id].parents(location)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment