Issue Separately process a single watcher unscheduling
@@ -369,6 +369,7 @@ class NFSMountWatcher:
def try_to_remove_path_from_observer(self, mnt_dest):
try:
+ if len(self._target_path_mapping.items()) > 1:
self._event_observer.unschedule(ObservedWatch(mnt_dest, True))
return True
except OSError as e:
@@ -681,6 +682,7 @@ class NFSMountWatcher:
def release_resources(self):
self._event_observer.stop()
+ if len(self._target_path_mapping.items()) > 1:
self._event_observer.unschedule_all()
self._event_handler.dump_to_storage()
