X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_common%2Ffsmongo.py;fp=osm_common%2Ffsmongo.py;h=f99267fc86bffffa7b6bc44bd8f5430b7614c477;hb=76394efe9fbee088dddd1dc9d4da6f043c3959a5;hp=727410e14a5fb21c405db4d4e97663160203a971;hpb=abe9dced7126c866b751acf560aee085d6d2d69d;p=osm%2Fcommon.git diff --git a/osm_common/fsmongo.py b/osm_common/fsmongo.py index 727410e..f99267f 100644 --- a/osm_common/fsmongo.py +++ b/osm_common/fsmongo.py @@ -570,9 +570,7 @@ class FsMongo(FsBase): self.__update_local_fs(from_path=from_path) def _update_mongo_fs(self, from_path): - os_path = self.path + from_path - # Obtain list of files and dirs in filesystem members = [] for root, dirs, files in os.walk(os_path): @@ -615,7 +613,6 @@ class FsMongo(FsBase): remote_files.pop(rel_filename, None) if last_modified_date >= upload_date: - stream = None fh = None try: @@ -646,13 +643,12 @@ class FsMongo(FsBase): if stream: stream.close() - # delete files that are not any more in local fs + # delete files that are not anymore in local fs for remote_file in remote_files.values(): for file in remote_file: self.fs.delete(file._id) def _get_mongo_files(self, from_path=None): - file_dict = {} file_cursor = self.fs.find(no_cursor_timeout=True, sort=[("uploadDate", -1)]) for file in file_cursor: