try:
if not self._reg.is_registered(src_file_path):
self._migrate_single(src_file_name, src_file_path, remove)
- self._reg.clean()
self._reg.register(src_file_path)
else:
self._reg.refresh(src_file_path)
except Exception as e:
logging.error('Error migrating %s: %s', src_file_path, str(e))
+ self._reg.clean()
def _migrate_single(self, src_file_name, src_file_path, remove):
meta_time = misc.extract_meta_time(src_file_path)